backend: send payload for binary serde

redpanda-data · Nov 28, 2023 · 91b1523 · 91b1523
1 parent ffa22d7
commit 91b1523
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/backend/pkg/serde/binary.go b/backend/pkg/serde/binary.go
@@ -27,9 +27,13 @@ func (BinarySerde) Name() PayloadEncoding {
 }
 
 // DeserializePayload deserializes the kafka record to our internal record payload representation.
-func (BinarySerde) DeserializePayload(_ context.Context, _ *kgo.Record, _ PayloadType) (*RecordPayload, error) {
+func (BinarySerde) DeserializePayload(_ context.Context, record *kgo.Record, payloadType PayloadType) (*RecordPayload, error) {
+	payload := payloadFromRecord(record, payloadType)
+
 	return &RecordPayload{
-		Encoding: PayloadEncodingBinary,
+		DeserializedPayload: payload,
+		NormalizedPayload:   payload, // The frontend will render these bytes
+		Encoding:            PayloadEncodingBinary,
 	}, nil
 }