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 2018/12/11 18:39:01 UTC
[5/8] storm git commit: Merge branch 'STORM-3301' of
https://github.com/srdo/storm into asfgit-master
Merge branch 'STORM-3301' of https://github.com/srdo/storm into asfgit-master
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/7340e849
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/7340e849
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/7340e849
Branch: refs/heads/master
Commit: 7340e849b7dd4bda70fd31f261ed421ea71e9bb3
Parents: 94cd157 8bb0185
Author: Stig Rohde Døssing <sr...@apache.org>
Authored: Tue Dec 11 19:32:24 2018 +0100
Committer: Stig Rohde Døssing <sr...@apache.org>
Committed: Tue Dec 11 19:32:24 2018 +0100
----------------------------------------------------------------------
.../apache/storm/kafka/spout/KafkaSpout.java | 35 ++++++------
.../kafka/spout/internal/OffsetManager.java | 1 +
.../KafkaSpoutLogCompactionSupportTest.java | 37 +++++++++++++
.../kafka/spout/KafkaSpoutSingleTopicTest.java | 56 ++++++++++++++++++++
4 files changed, 113 insertions(+), 16 deletions(-)
----------------------------------------------------------------------