Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Key and partitioning support for arbitrary JMS Headers #93

Open
j0xaf opened this issue Apr 1, 2022 · 1 comment
Open

Key and partitioning support for arbitrary JMS Headers #93

j0xaf opened this issue Apr 1, 2022 · 1 comment

Comments

@j0xaf
Copy link

j0xaf commented Apr 1, 2022

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!

@jhughes24816
Copy link
Contributor

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.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants