rgannu commented on issue #323: URL: https://github.com/apache/camel-kafka-connector/issues/323#issuecomment-682415645
Hi @davsclaus I think you got carried away when I asked about how to configure camel beans. Fine for me to document via the ticket https://issues.apache.org/jira/browse/CAMEL-15389 Still the initial problem for me exists. i.e., How I can set a map of headers via the sink connector configuration ? I had a look into the source code of camel sink connector and I can see that it only processes the header from the kafka message (sink record) and processes it. (https://github.com/apache/camel-kafka-connector/blob/master/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java#L140) My proposal is to give support there to add additional headers, so that sink connector implementation classes (like CamelRabbitMQSinkTask) can if they want add the additional headers. This would be quite useful for any sink connectors which want to add additional headers on the fly via sink connector configuration itself. To add the additional headers, I could also write kafka SMT but that means that I am extracting the message every time in the SMT and it could be less performant. I will submit a PR for this. Please review the same and give your valuable comments. ---------------------------------------------------------------- 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
