camel-kafka-connector icon indicating copy to clipboard operation
camel-kafka-connector copied to clipboard

Published 20 hours ago • verified publisher icon apache

Reading headers from SQS message

Open gaganbajaj5 opened this issue 1 year ago • 0 comments

Hi, We have a AWS2SQS Kafka source connector (V0.11.0) running in Kafka connect with connector.class = org.apache.camel.kafkaconnector.aws2sqs.CamelAws2sqsSourceConnector

By default, the connector reads the Body of the message and pushes it into our Kafka topic. But we have a new requirement which needs us to push headers (MessageAttributes) from SQS into the Kafka topic. Unfortunately, i am not able to find anything in the documentation or the example specified anywhere, would you be able to guide how can I achieve this? I was thinking if there is a way to use custom transforms, but is there a better way library provides out of the box with connector?

gaganbajaj5 avatar Jan 29 '24 16:01 gaganbajaj5