kkonstantine commented on a change in pull request #11933:
URL: https://github.com/apache/kafka/pull/11933#discussion_r832882438
##########
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java
##########
@@ -648,6 +648,14 @@ private WorkerTask buildWorkerTask(ClusterConfigState
configState,
// These settings will execute infinite retries on retriable
exceptions. They *may* be overridden via configs passed to the worker,
// but this may compromise the delivery guarantees of Kafka Connect.
producerProps.put(ProducerConfig.MAX_BLOCK_MS_CONFIG,
Long.toString(Long.MAX_VALUE));
+ // By default, producers that are instantiated and used by Connect
have idempotency disabled even after idempotency became
+ // default for Kafka producers. This is chosen to avoid breaking
changes when Connect contacts Kafka brokers that do not support
Review comment:
Thanks for the suggestion. Added it in all places
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
