diff --git a/internal/processor/json-encode.go b/internal/processor/json-encode.go index 5036a39..acfd12f 100644 --- a/internal/processor/json-encode.go +++ b/internal/processor/json-encode.go @@ -21,7 +21,11 @@ func (je *JsonEncode) Process(ctx context.Context, payload any) (any, error) { return nil, err } - return payloadBuffer.Bytes(), nil + payloadBytes := payloadBuffer.Bytes() + + payloadBytes = payloadBytes[0 : len(payloadBytes)-1] + + return payloadBytes, nil } func (je *JsonEncode) Type() string {