storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From srihar...@apache.org
Subject [2/3] storm git commit: Merge branch 'STORM-2343' of https://github.com/srdo/storm
Date Mon, 01 May 2017 20:48:24 GMT
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 <harsha@hortonworks.com>
Authored: Mon May 1 12:55:31 2017 -0700
Committer: Sriharsha Chintalapani <harsha@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
----------------------------------------------------------------------


Mime
View raw message