storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject [1/3] git commit: STORM-399 update KafkaConfig.maxOffsetBehind default to be Long.MAX_VALUE
Date Thu, 24 Jul 2014 21:59:09 GMT
Repository: incubator-storm
Updated Branches:
  refs/heads/master 3c55b103d -> 3a19ccc84


STORM-399 update KafkaConfig.maxOffsetBehind default to be Long.MAX_VALUE


Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/2b1d6cfe
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/2b1d6cfe
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/2b1d6cfe

Branch: refs/heads/master
Commit: 2b1d6cfe9b3d567234246b2e01bfb02b64131302
Parents: 8da9572
Author: Curtis Allen <curtis.allen@pearson.com>
Authored: Wed Jul 9 15:43:14 2014 -0600
Committer: Curtis Allen <curtis.allen@pearson.com>
Committed: Wed Jul 9 15:43:14 2014 -0600

----------------------------------------------------------------------
 external/storm-kafka/src/jvm/storm/kafka/KafkaConfig.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/2b1d6cfe/external/storm-kafka/src/jvm/storm/kafka/KafkaConfig.java
----------------------------------------------------------------------
diff --git a/external/storm-kafka/src/jvm/storm/kafka/KafkaConfig.java b/external/storm-kafka/src/jvm/storm/kafka/KafkaConfig.java
index 9c156e8..5c85983 100644
--- a/external/storm-kafka/src/jvm/storm/kafka/KafkaConfig.java
+++ b/external/storm-kafka/src/jvm/storm/kafka/KafkaConfig.java
@@ -35,7 +35,7 @@ public class KafkaConfig implements Serializable {
     public MultiScheme scheme = new RawMultiScheme();
     public boolean forceFromStart = false;
     public long startOffsetTime = kafka.api.OffsetRequest.EarliestTime();
-    public long maxOffsetBehind = 100000;
+    public long maxOffsetBehind = Long.MAX_VALUE;
     public boolean useStartOffsetTimeIfOffsetOutOfRange = true;
     public int metricsTimeBucketSizeInSecs = 60;
 


Mime
View raw message