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 <[email protected]> Authored: Mon Sep 8 20:58:01 2014 +0000 Committer: rick-kilgore <[email protected]> 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);
