Delayed retry mechanism in Sink connector

Kafka Connect
1

I want to implement delayed retry mechanism in Sink connector , I see that if we throw
RetriableException from put method, events are retried.
I found the following two properties to introduce a delay in subsequent retries but it is not taking effect.
“errors.retry.timeout”:600000,
“errors.retry.delay.max.ms”:300000,

I have put these two in the connectors config. I am using kafka-connect 2.6 APIs.

Kafka confluence doc : KIP-298: Error Handling in Connect - Apache Kafka - Apache Software Foundation
Kafka public doc : Apache Kafka
RetriableException: https://github.com/jcustenborder/kafka-connect-solr/blob/c917b5c8e938575b6880729f3dbbb7cac4062cb8/src/main/java/com/github/jcustenborder/kafka/connect/solr/SolrSinkTask.java

2

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.