You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jk...@apache.org on 2014/03/05 23:15:07 UTC
git commit: KAFKA-1286 Follow-up comment from Jun: Change the backoff
default time configuration.
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 <ja...@gmail.com>
Authored: Wed Mar 5 13:32:08 2014 -0800
Committer: Jay Kreps <ja...@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) {