Skip to content

Releases: ibm-messaging/kafka-connect-mq-sink

Release v2.2.1

04 Oct 09:10
96bf282
Compare
Choose a tag to compare

What's Changed

New Contributors

Full Changelog: v2.2.0...v2.2.1

Release v2.2.0

07 Aug 12:14
a187590
Compare
Choose a tag to compare

What's Changed

Version 2.2.0 of the MQ Sink Connector introduces exactly-once message delivery, ensuring that each MQ message is delivered to Kafka exactly once with no duplicates. This improvement uses an additional MQ queue to track message delivery states, enhancing reliability and eliminating duplicates even in failure scenarios. Upgrade to this version for more consistent and accurate message delivery.

Full Changelog: v1.5.2...v2.2.0

Release v1.5.2

02 Oct 10:14
3bd3bdb
Compare
Choose a tag to compare
chore: Update mq allclient, log4j and junit versions (#62)

Signed-off-by: Joel Hanson <joel.hanson2@ibm.com>

Release v1.5.0

29 Apr 14:34
af9111d
Compare
Choose a tag to compare
feat: configurable retry interval after retriable exceptions (#54)

If the connector throws a retriable exception, there is no need
for Connect's Kafka consumer to wait for as long to re-consume
messages from the Kafka topic. It's therefore helpful to be able
to specify that the consumer should use a shorter timeout for
polls immediately following a retriable exception.

This commit introduces a new config parameter mq.retry.backoff.ms
which allows this to be controlled.

By default, it is set to 1 minute, which is how long it
currently waits.

Signed-off-by: Dale Lane <dale.lane@uk.ibm.com>

Release v1.4.0

27 Mar 15:53
ea8a06c
Compare
Choose a tag to compare
feat: support for copying Kafka headers to MQ message properties (#53)

This pull request introduces a new feature to the MQ Sink Connector.
If enabled, all headers on messages consumed from Kafka will be added to
messages put to MQ as string properties.

The feature is named to be consistent with the equivalent feature in
the MQ Source Connector (`mq.kafka.headers.copy.to.jms.properties` where
the Source Connector currently has 
`mq.jms.properties.copy.to.kafka.headers`)

The new feature is disabled by default to maintain compatibility with
current behaviour.

Closes: #52 

Signed-off-by: Dale Lane <dale.lane@uk.ibm.com>

Release v1.3.1

25 Sep 14:32
abdd6dc
Compare
Choose a tag to compare

v1.3.1 Updates the Kafka client to 2.6.
The release matches the version delivered alongside IBM Cloud Pak for Integration 2020.3.1 which includes Event Streams v10.1.0.

v1.3.0

16 Jun 13:48
cb9a0ab
Compare
Choose a tag to compare

v1.3.0 adds more flexible TLS configuration, optimises batching, and updates the support for Docker, Kubernetes and OpenShift. The release matches the version delivered alongside IBM Cloud Pak for Integration 2020.2.1 which includes Event Streams v10.0.0.

v1.2.0

09 Apr 12:47
139fa38
Compare
Choose a tag to compare

v1.2.0 adds the ability to use an MQCSP, JMS properties from the topic, partition and offset information in Kafka, and configuration for SSL keystores. The release matches the version delivered in Event Streams 2019.4.2.

v1.1.1

24 Oct 21:15
Compare
Choose a tag to compare

v1.1.1 adds handling of ClassCastException to help debugging class loading problems, configuration for distributed mode and configuration in Kubernetes using a secret. The release matches the version delivered in IBM Event Streams 2019.4.1.

v1.1.0

27 Jun 18:54
Compare
Choose a tag to compare

v1.1.0 adds support for reply queue, a dockerfile and Kubernetes manifest. The release matches the version delivered in IBM Event Streams 2019.2.1.