MINOR: Producers should set delivery timeout instead of retries (#5425)
Use delivery timeout instead of retries when possible and remove various TODOs associated with completion of KIP-91. Reviewers: Ismael Juma <ismael@juma.me.uk>, Guozhang Wang <wangguoz@gmail.com>
Showing
- clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java 1 addition, 1 deletion...java/org/apache/kafka/clients/producer/KafkaProducer.java
- clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java 16 additions, 8 deletions...ava/org/apache/kafka/clients/producer/ProducerConfig.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java 0 additions, 1 deletion...rc/main/java/org/apache/kafka/connect/runtime/Worker.java
- connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java 1 addition, 1 deletion...apache/kafka/connect/storage/KafkaConfigBackingStore.java
- connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java 1 addition, 1 deletion...apache/kafka/connect/storage/KafkaOffsetBackingStore.java
- core/src/main/scala/kafka/tools/MirrorMaker.scala 5 additions, 5 deletionscore/src/main/scala/kafka/tools/MirrorMaker.scala
- core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala 0 additions, 2 deletions...ala/integration/kafka/api/AuthorizerIntegrationTest.scala
- core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala 4 additions, 2 deletions...st/scala/integration/kafka/api/BaseProducerSendTest.scala
- core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala 5 additions, 5 deletions...ala/integration/kafka/api/EndToEndAuthorizationTest.scala
- core/src/test/scala/integration/kafka/api/IntegrationTestHarness.scala 10 additions, 10 deletions.../scala/integration/kafka/api/IntegrationTestHarness.scala
- core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala 1 addition, 1 deletion...t/scala/integration/kafka/api/PlaintextConsumerTest.scala
- core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala 1 addition, 2 deletions...ala/integration/kafka/api/PlaintextProducerSendTest.scala
- core/src/test/scala/integration/kafka/api/ProducerFailureHandlingTest.scala 3 additions, 3 deletions...a/integration/kafka/api/ProducerFailureHandlingTest.scala
- core/src/test/scala/integration/kafka/api/RackAwareAutoTopicCreationTest.scala 1 addition, 1 deletion...ntegration/kafka/api/RackAwareAutoTopicCreationTest.scala
- core/src/test/scala/integration/kafka/api/SaslClientsWithInvalidCredentialsTest.scala 0 additions, 1 deletion...ion/kafka/api/SaslClientsWithInvalidCredentialsTest.scala
- core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala 11 additions, 6 deletions...ation/kafka/server/DynamicBrokerReconfigurationTest.scala
- core/src/test/scala/other/kafka/ReplicationQuotasTestRig.scala 1 addition, 1 deletion...src/test/scala/other/kafka/ReplicationQuotasTestRig.scala
- core/src/test/scala/unit/kafka/server/FetchRequestDownConversionConfigTest.scala 1 addition, 1 deletion...t/kafka/server/FetchRequestDownConversionConfigTest.scala
- core/src/test/scala/unit/kafka/server/FetchRequestTest.scala 5 additions, 4 deletionscore/src/test/scala/unit/kafka/server/FetchRequestTest.scala
- core/src/test/scala/unit/kafka/server/LogDirFailureTest.scala 11 additions, 5 deletions.../src/test/scala/unit/kafka/server/LogDirFailureTest.scala
Loading
Please register or sign in to comment