kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jkr...@apache.org
Subject git commit: KAFKA-1286 Follow-up comment from Jun: Change the backoff default time configuration.
Date Wed, 05 Mar 2014 22:15:07 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 5ba48348b -> 2404191be


KAFKA-1286 Follow-up comment from Jun: Change the backoff default time configuration.


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

Branch: refs/heads/trunk
Commit: 2404191be9f4323fc6144a8f56ae36f794d50da6
Parents: 5ba4834
Author: Jay Kreps <jay.kreps@gmail.com>
Authored: Wed Mar 5 13:32:08 2014 -0800
Committer: Jay Kreps <jay.kreps@gmail.com>
Committed: Wed Mar 5 13:32:08 2014 -0800

----------------------------------------------------------------------
 .../java/org/apache/kafka/clients/producer/ProducerConfig.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/2404191b/clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java b/clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
index 307659c..f874896 100644
--- a/clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
+++ b/clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
@@ -167,7 +167,7 @@ public class ProducerConfig extends AbstractConfig {
                                 .define(BLOCK_ON_BUFFER_FULL_CONFIG, Type.BOOLEAN, true,
"blah blah")
                                 .define(ENABLE_JMX_CONFIG, Type.BOOLEAN, true, "")
                                 .define(MAX_RETRIES_CONFIG, Type.INT, 0, between(0, Integer.MAX_VALUE),
"")
-                                .define(RETRY_BACKOFF_MS_CONFIG, Type.LONG, 500L, atLeast(0L),
"blah blah");
+                                .define(RETRY_BACKOFF_MS_CONFIG, Type.LONG, 100L, atLeast(0L),
"blah blah");
     }
 
     ProducerConfig(Map<? extends Object, ? extends Object> props) {


Mime
View raw message