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:47 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk ab148f39a -> e19bf3f24


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


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

Branch: refs/heads/trunk
Commit: e19bf3f24466cd8dcd6c11f2d7cbc5796600fb88
Parents: ab148f3
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:32 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/e19bf3f2/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 52721ef..078877f 100644
--- a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
+++ b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
@@ -391,6 +391,7 @@ public class StreamsConfig extends AbstractConfig {
     static {
         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