kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: KAFKA-5040; Increase number of retries from the default of 0
Date Fri, 07 Apr 2017 12:39:56 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.2 51ae9c249 -> 47f9e8fe2


KAFKA-5040; Increase number of retries from the default of 0

Author: Eno Thereska <eno@confluent.io>

Reviewers: Damian Guy <damian.guy@gmail.com>, Matthias J. Sax <matthias@confluent.io>,
Ismael Juma <ismael@juma.me.uk>

Closes #2819 from enothereska/minor-increase-retries

(cherry picked from commit e19bf3f24466cd8dcd6c11f2d7cbc5796600fb88)
Signed-off-by: Ismael Juma <ismael@juma.me.uk>


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/47f9e8fe
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/47f9e8fe
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/47f9e8fe

Branch: refs/heads/0.10.2
Commit: 47f9e8fe2cf7911e24d87ee6527362b2cc9ec306
Parents: 51ae9c2
Author: Eno Thereska <eno@confluent.io>
Authored: Fri Apr 7 13:39:32 2017 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Fri Apr 7 13:39:53 2017 +0100

----------------------------------------------------------------------
 streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/47f9e8fe/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
index 3d22742..bc73f24 100644
--- a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
+++ b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
@@ -393,6 +393,7 @@ public class StreamsConfig extends AbstractConfig {
     {
         final Map<String, Object> tempProducerDefaultOverrides = new HashMap<>();
         tempProducerDefaultOverrides.put(ProducerConfig.LINGER_MS_CONFIG, "100");
+        tempProducerDefaultOverrides.put(ProducerConfig.RETRIES_CONFIG, 10);
 
         PRODUCER_DEFAULT_OVERRIDES = Collections.unmodifiableMap(tempProducerDefaultOverrides);
     }


Mime
View raw message