Copy custom record headers to JMS properties

macronova / kafka-connect-jms

Sink and source capabilities to transfer messages between JMS server and Kafka brokers

Apache License 2.0

17 stars 17 forks source link

Copy custom record headers to JMS properties #6

Open michaelomichael opened 7 months ago

michaelomichael commented 7 months ago

An enhancement to the StandardJmsConverter class to copy across any headers from the Kafka record into the JMS message's properties as part of sink connector processing.

The datatype conversion uses the same mechanism as is already in-place for setting the KafkaKey JMS message property.

Added both "queue" and "topic" tests for the sink connector.

u-ways-e commented 7 months ago

@macronova can you have a look please? We also need this :)