You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2017/05/01 20:48:24 UTC
[2/3] storm git commit: Merge branch 'STORM-2343' of
https://github.com/srdo/storm
Merge branch 'STORM-2343' of https://github.com/srdo/storm
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/d39e3a77
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/d39e3a77
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/d39e3a77
Branch: refs/heads/master
Commit: d39e3a778873b36af9c120a71c81b883cefc674b
Parents: a4afacd d98a5b8
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Mon May 1 12:55:31 2017 -0700
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Mon May 1 12:55:31 2017 -0700
----------------------------------------------------------------------
.../apache/storm/kafka/spout/KafkaSpout.java | 26 +-
.../storm/kafka/spout/KafkaSpoutConfig.java | 10 +-
.../KafkaSpoutRetryExponentialBackoff.java | 73 ++++--
.../kafka/spout/KafkaSpoutRetryService.java | 10 +-
.../storm/kafka/spout/KafkaSpoutEmitTest.java | 250 +++++++++++++++++++
.../kafka/spout/KafkaSpoutRebalanceTest.java | 11 +-
.../kafka/spout/MaxUncommittedOffsetTest.java | 240 ++++++++++++++++++
.../kafka/spout/SingleTopicKafkaSpoutTest.java | 56 +++--
.../SingleTopicKafkaSpoutConfiguration.java | 19 +-
9 files changed, 616 insertions(+), 79 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/d39e3a77/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java
----------------------------------------------------------------------