kafka-connect-mq-source icon indicating copy to clipboard operation
kafka-connect-mq-source copied to clipboard

Key and partitioning support for arbitrary JMS Headers

Open j0xaf opened this issue 3 years ago • 1 comments

Currently, kafka-connect-mq-source supports three distinct (logical) sources for specifying the kafka key: JMSMessageID, JMSCorrelationID (as well as the Bytes variant) and JMSDestination (see https://github.com/ibm-messaging/kafka-connect-mq-source#key-support-and-partitioning).

We would like, however, to use a custom JMS Header for populating the kafka key. Is there any specific reason why you chose to limit support to those three possibilities and not arbitrary JMS Headers? Would you accept a PR to support arbitrary JMS Headers?

Thank you for providing this connector!

j0xaf avatar Apr 01 '22 12:04 j0xaf

Hi @j0xaf Apologies for the long wait on this issue. This seems a worthwhile addition to the connector and we would happily welcome any contributions (you can find the contributions guide here)

I will also raise this with the development team to take a look at.

jhughes24816 avatar May 05 '23 14:05 jhughes24816