In case of duplicate headers, headers from kafka-message should be re…

…tained Signed-off-by: Md Soharab Ansari <[email protected]>
fission · Oct 23, 2024 · dae8ceb · dae8ceb
1 parent b4b8853
commit dae8ceb
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/kafka-http-connector/main.go b/kafka-http-connector/main.go
@@ -220,7 +220,7 @@ func (conn *kafkaConnector) ConsumeClaim(session sarama.ConsumerGroupSession, cl
 		// Set the headers came from Kafka record
 		for _, h := range message.Headers {
 			if utf8.ValidString(string(h.Value)) {
-				headers.Add(string(h.Key), string(h.Value))
+				headers.Set(string(h.Key), string(h.Value))
 			}
 		}
 

diff --git a/kafka-http-connector/version b/kafka-http-connector/version
@@ -1 +1 @@
-v0.17
+v0.18