Skip to content

Commit

Permalink
Fixes #190
Browse files Browse the repository at this point in the history
  • Loading branch information
weeco committed Mar 18, 2021
1 parent 3cf4b9a commit 6c47088
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion backend/pkg/kafka/deserializer.go
Original file line number Diff line number Diff line change
Expand Up @@ -155,7 +155,7 @@ func (d *deserializer) deserializePayload(payload []byte, topicName string, reco
if err == nil {
native, _, err := codec.NativeFromBinary(payload[5:])
if err == nil {
normalized, _ := json.Marshal(native)
normalized, _ := codec.TextualFromNative(nil, native)
return &deserializedPayload{
Payload: normalizedPayload{
Payload: normalized,
Expand Down

0 comments on commit 6c47088

Please sign in to comment.