You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by da...@apache.org on 2014/07/24 23:59:09 UTC
[1/3] git commit: STORM-399 update KafkaConfig.maxOffsetBehind
default to be Long.MAX_VALUE
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 <cu...@pearson.com>
Authored: Wed Jul 9 15:43:14 2014 -0600
Committer: Curtis Allen <cu...@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;
[3/3] git commit: Updating contributors and CHANGELOG for STORM-399
Posted by da...@apache.org.
Updating contributors and CHANGELOG for STORM-399
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/3a19ccc8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/3a19ccc8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/3a19ccc8
Branch: refs/heads/master
Commit: 3a19ccc8450638b1028c81d792d97fcbf226fbf5
Parents: e9238bc
Author: Derek Dagit <de...@yahoo-inc.com>
Authored: Thu Jul 24 16:58:01 2014 -0500
Committer: Derek Dagit <de...@yahoo-inc.com>
Committed: Thu Jul 24 16:58:01 2014 -0500
----------------------------------------------------------------------
CHANGELOG.md | 1 +
README.markdown | 1 +
2 files changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/3a19ccc8/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index f78dd62..366a401 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -25,6 +25,7 @@
* STORM-402: FileNotFoundException when using storm with apache tika
* STORM-364: The exception time display as default timezone.
* STORM-420: Missing quotes in storm-starter python code
+ * STORM-399: Kafka Spout defaulting to latest offset when current offset is older then 100k
## 0.9.2-incubating
* STORM-66: send taskid on initial handshake
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/3a19ccc8/README.markdown
----------------------------------------------------------------------
diff --git a/README.markdown b/README.markdown
index f5d7873..cf67f64 100644
--- a/README.markdown
+++ b/README.markdown
@@ -158,6 +158,7 @@ under the License.
* Dave Parfitt ([@metadave](https://github.com/metadave))
* Jo Liss ([@joliss](https://github.com/joliss))
* averykhoo ([@averykhoo](https://github.com/averykhoo))
+* Curtis Allen ([@curtisallen](https://github.com/curtisallen))
## Acknowledgements
[2/3] git commit: Merge branch
'STORM-399-kafka-spout-increase-default' of
https://github.com/curtisallen/incubator-storm into STORM-399
Posted by da...@apache.org.
Merge branch 'STORM-399-kafka-spout-increase-default' of https://github.com/curtisallen/incubator-storm into STORM-399
STORM-399: Kafka Spout defaulting to latest offset when current offset
is older then 100k
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/e9238bcd
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/e9238bcd
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/e9238bcd
Branch: refs/heads/master
Commit: e9238bcd15fc7b7eb19e2bd34a8b2968eaa7edd0
Parents: 3c55b10 2b1d6cf
Author: Derek Dagit <de...@yahoo-inc.com>
Authored: Thu Jul 24 16:56:14 2014 -0500
Committer: Derek Dagit <de...@yahoo-inc.com>
Committed: Thu Jul 24 16:56:14 2014 -0500
----------------------------------------------------------------------
external/storm-kafka/src/jvm/storm/kafka/KafkaConfig.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------