codexetreme commented on issue #410: URL: https://github.com/apache/camel-kafka-connector/issues/410#issuecomment-687256280
So, right now , as per my understanding, and experiments, when the source connector runs, it inserts the sqs message ID as the header for the Kafka record. Leaving the key of the record null. My requirement is that , I want to basically parse the data from the sqs message, and depending on the data in the message, I want to set a key for the Kafka record. If that is not possible, I want then perhaps set the header to the extracted key, because either way, I need the key that I get from the sqs message data. Please let me know if my explanation is clear, if not I can elaborate further ________________________________ From: Andrea Cosentino <notificati...@github.com> Sent: Friday, September 4, 2020 7:22:22 PM To: apache/camel-kafka-connector <camel-kafka-connec...@noreply.github.com> Cc: Yashodhan Ghadge <yashodhangha...@gmail.com>; Mention <ment...@noreply.github.com> Subject: Re: [apache/camel-kafka-connector] IMPROVEMENT REQUEST: Add a transformer mode to the connectors to make lightweight edits to the messages while they are being produced/consumed (#410) It's possibile I don't get what you're asking well anyway. So what is the use case for you to set an header in the connector? What do you want to set? — You are receiving this because you were mentioned. Reply to this email directly, view it on GitHub<https://github.com/apache/camel-kafka-connector/issues/410#issuecomment-687249773>, or unsubscribe<https://github.com/notifications/unsubscribe-auth/ACCHNM6RONNQGS5K3DNUUF3SEEH35ANCNFSM4QS2POTA>. ---------------------------------------------------------------- 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
