You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2018/07/09 03:34:48 UTC
[2/2] storm git commit: Merge branch 'STORM-3013' of
https://github.com/srdo/storm into STORM-3013-merge
Merge branch 'STORM-3013' of https://github.com/srdo/storm into STORM-3013-merge
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/6872adfc
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/6872adfc
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/6872adfc
Branch: refs/heads/master
Commit: 6872adfc260a9417e4dadc0e1c867476ed45bce6
Parents: db86bad 528ab30
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Mon Jul 9 12:33:37 2018 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Mon Jul 9 12:33:37 2018 +0900
----------------------------------------------------------------------
.../apache/storm/kafka/spout/KafkaSpout.java | 49 +++++++++---------
.../kafka/spout/metrics/KafkaOffsetMetric.java | 9 ++--
.../kafka/spout/KafkaSpoutAbstractTest.java | 6 ++-
.../kafka/spout/KafkaSpoutReactivationTest.java | 53 ++++++++++++++------
.../kafka/spout/KafkaSpoutSingleTopicTest.java | 2 +-
...outTopologyDeployActivateDeactivateTest.java | 2 -
6 files changed, 73 insertions(+), 48 deletions(-)
----------------------------------------------------------------------