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

soharab-ic · soharab-ic · commit dae8ceb618e0 · 2024-10-23T16:23:32.000+05:30
Signed-off-by: Md Soharab Ansari &lt;soharab.ansari@infracloud.io&gt;
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

Original file line number	Diff line number	Diff line change
`@@ -220,7 +220,7 @@ func (conn *kafkaConnector) ConsumeClaim(session sarama.ConsumerGroupSession, cl`
`220`	`220`	`// Set the headers came from Kafka record`
`221`	`221`	`for _, h := range message.Headers {`
`222`	`222`	`if utf8.ValidString(string(h.Value)) {`
`223`		`- headers.Add(string(h.Key), string(h.Value))`
	`223`	`+ headers.Set(string(h.Key), string(h.Value))`
`224`	`224`	`}`
`225`	`225`	`}`
`226`	`226`