oscerd commented on issue #988: URL: https://github.com/apache/camel-kafka-connector/issues/988#issuecomment-814100539
@swierszczu4j I opened this PR on your reproducer https://github.com/swierszczu4j/camel-kafka-kafka-connector-problem/pull/1/files Basically you need to add a "CamelHeader.kafka.KEY" header with the key value while sending message to the inbound topic. I know it wasn't clear completely, but it's not easy to generalize the Camel Headers usage in the ckc context. Please let me know if it works for you and sorry for the long delay. -- 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