Merge branch 'STORM-2913' of https://github.com/srdo/storm into STORM-2913-merge
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/b5d70e17 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/b5d70e17 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/b5d70e17 Branch: refs/heads/master Commit: b5d70e17d798f91417b74863772f0826b4a84625 Parents: ffa5f05 e756889 Author: Jungtaek Lim <kabh...@gmail.com> Authored: Mon Feb 5 10:57:33 2018 +0900 Committer: Jungtaek Lim <kabh...@gmail.com> Committed: Mon Feb 5 10:57:33 2018 +0900 ---------------------------------------------------------------------- .../apache/storm/kafka/spout/KafkaSpout.java | 80 ++++++----------- .../storm/kafka/spout/KafkaSpoutConfig.java | 4 +- .../spout/internal/CommitMetadataManager.java | 91 ++++++++++++++++++++ .../spout/KafkaSpoutMessagingGuaranteeTest.java | 45 ++++++---- 4 files changed, 146 insertions(+), 74 deletions(-) ----------------------------------------------------------------------
