add comment and different default for retry
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/04b64bc6 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/04b64bc6 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/04b64bc6 Branch: refs/heads/master Commit: 04b64bc66d5c29ba77c455f0125200ed8335376f Parents: 1c748a7 Author: rick-kilgore <[email protected]> Authored: Mon Sep 8 20:49:18 2014 +0000 Committer: rick-kilgore <[email protected]> Committed: Mon Sep 8 20:49:18 2014 +0000 ---------------------------------------------------------------------- external/storm-kafka/src/jvm/storm/kafka/SpoutConfig.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/04b64bc6/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 d8ca7eb..9a5c311 100644 --- a/external/storm-kafka/src/jvm/storm/kafka/SpoutConfig.java +++ b/external/storm-kafka/src/jvm/storm/kafka/SpoutConfig.java @@ -27,9 +27,12 @@ public class SpoutConfig extends KafkaConfig implements Serializable { public String zkRoot = null; public String id = null; public long stateUpdateIntervalMs = 2000; - public long retryInitialDelayMs = 10 * 1000; - public double retryDelayMultiplier = 1.5; - public long retryMaxDelayMs = 5 * 60 * 1000; + + // 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 double retryDelayMultiplier = 1.0; + public long retryMaxDelayMs = 1000; public SpoutConfig(BrokerHosts hosts, String topic, String zkRoot, String id) { super(hosts, topic);
