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

feat: configurable retry interval after retriable exceptions #54

Closed dalelane closed 1 year ago

dalelane commented 1 year ago

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.