updated AddMessageHeaders

xmidt-org · Aug 27, 2024 · 8d86d4c · 8d86d4c
1 parent 1d151f5
commit 8d86d4c
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/internal/sink/sink.go b/internal/sink/sink.go
@@ -456,9 +456,10 @@ func AddMessageHeaders(kafkaMsg *sarama.ProducerMessage, m *wrp.Message) {
 		})
 	}
 
-	// for _, v := range m.Headers {
-	// 	h.Add(HeadersHeader, v)
-	// }
+	kafkaMsg.Headers = append(kafkaMsg.Headers, sarama.RecordHeader{
+		Key:   []byte(wrphttp.HeadersHeader),
+		Value: []byte(strings.Join(m.Headers, ",")),
+	})
 
 	if len(m.ServiceName) > 0 {
 		kafkaMsg.Headers = append(kafkaMsg.Headers, sarama.RecordHeader{