Merge branch 'kafka-spout-leader-change-bug-2361' of https://github.com/ernisv/storm into STORM-2361-1.x-merge
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/b65e0bfd Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/b65e0bfd Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/b65e0bfd Branch: refs/heads/1.x-branch Commit: b65e0bfda1dcc3bdd6e3c1cc72f12169187beddd Parents: 805ea40 25fde12 Author: Jungtaek Lim <[email protected]> Authored: Fri Mar 10 00:55:52 2017 +0900 Committer: Jungtaek Lim <[email protected]> Committed: Fri Mar 10 00:55:52 2017 +0900 ---------------------------------------------------------------------- .../jvm/org/apache/storm/kafka/KafkaSpout.java | 21 ++++++++++++++++++++ 1 file changed, 21 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/b65e0bfd/external/storm-kafka/src/jvm/org/apache/storm/kafka/KafkaSpout.java ----------------------------------------------------------------------
