search

ibm-messaging / kafka-connect-mq-sink

This repository contains a Kafka Connect sink connector for copying data from Apache Kafka into IBM MQ.
Apache License 2.0
35 stars 43 forks source link

mq.jms.properties.copy.to.kafka.headers for MQ sink connector #45

Closed pierre-degrandmaison closed 1 year ago

pierre-degrandmaison commented 2 years ago

MQ source connector has mq.jms.properties.copy.to.kafka.headers Whether to copy JMS message properties to Kafka headers

I was expecting the reverse for the MQ sink connector, but the closer I found was this: mq.message.builder.topic.property The JMS message property to set from the Kafka topic

it seams to be set from Kafka topic? not Kafka header? I did not find any example of "mq.message.builder.topic.property".

is there an MQ sink equivalent to MQ source mq.jms.properties.copy.to.kafka.headers??

andrijadukic-syntio commented 1 year ago

Is there any update regarding this? This seems like it should be done by default, as you would expect the Kafka record headers to be mapped seamlessly to the IBM MQ equivalent. It seems to me this could simply be added to the BaseMessageBuilder class by iterating through the Kafka headers.

dalelane commented 1 year ago

Closing as this has now been implemented in Release 1.4.0