valdar commented on issue #1192: URL: https://github.com/apache/camel-kafka-connector/issues/1192#issuecomment-854801505
Hello @seravat > Thanks for the response Andrea, > > I am setting this header before sending to kafka: > I assume you are sending to kafka using a traditional camel route? > ``` > exchange.getIn().setHeader("indexId", exchangeId); > ``` > > So you are saying it should be: ? > > ``` > exchange.getIn().setHeader("CamelHeader.indexId", exchangeId); > ``` > > Is that right? It depends on how you produce event in the topic; the goal is that the produced event on the topic should have an Header named `CamelHeader.indexId` with value `exchangeId`. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org