You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2015/01/14 17:05:27 UTC
[06/44] storm git commit: default settings = no retry delay
default settings = no retry delay
default settings = no retry delay - i.e., preserve legacy behavior
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/05336764
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/05336764
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/05336764
Branch: refs/heads/master
Commit: 05336764408921f3ebcc4ac5b3e82da10e713bea
Parents: 04b64bc
Author: rick-kilgore <ri...@gmail.com>
Authored: Mon Sep 8 20:58:01 2014 +0000
Committer: rick-kilgore <ri...@gmail.com>
Committed: Mon Sep 8 20:58:01 2014 +0000
----------------------------------------------------------------------
external/storm-kafka/src/jvm/storm/kafka/SpoutConfig.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/05336764/external/storm-kafka/src/jvm/storm/kafka/SpoutConfig.java
----------------------------------------------------------------------
diff --git a/external/storm-kafka/src/jvm/storm/kafka/SpoutConfig.java b/external/storm-kafka/src/jvm/storm/kafka/SpoutConfig.java
index 9a5c311..5a5d6f4 100644
--- a/external/storm-kafka/src/jvm/storm/kafka/SpoutConfig.java
+++ b/external/storm-kafka/src/jvm/storm/kafka/SpoutConfig.java
@@ -30,9 +30,9 @@ public class SpoutConfig extends KafkaConfig implements Serializable {
// Exponential back-off retry settings - note: be sure to set backtype.storm.Config.MESSAGE_TIMEOUT_SECS
// appropriately to prevent resubmitting the message while still retrying
- public long retryInitialDelayMs = 1000;
+ public long retryInitialDelayMs = 0;
public double retryDelayMultiplier = 1.0;
- public long retryMaxDelayMs = 1000;
+ public long retryMaxDelayMs = 60 * 1000;
public SpoutConfig(BrokerHosts hosts, String topic, String zkRoot, String id) {
super(hosts, topic);