Merge branch 'kafka_spout_no_dup_on_leader_changes_1_x' of https://github.com/ernisv/storm into STORM-2296-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/c9fb7a4b Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/c9fb7a4b Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/c9fb7a4b Branch: refs/heads/1.x-branch Commit: c9fb7a4b9661cc92acaf4a9fc4284b61200d39bf Parents: d9efb5e b076399 Author: Jungtaek Lim <kabh...@gmail.com> Authored: Sat Feb 4 08:00:47 2017 +0900 Committer: Jungtaek Lim <kabh...@gmail.com> Committed: Sat Feb 4 08:00:47 2017 +0900 ---------------------------------------------------------------------- .../apache/storm/kafka/PartitionManager.java | 125 ++++++++++++------- .../org/apache/storm/kafka/ZkCoordinator.java | 16 ++- .../apache/storm/kafka/ZkCoordinatorTest.java | 42 ++++++- 3 files changed, 131 insertions(+), 52 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/c9fb7a4b/external/storm-kafka/src/jvm/org/apache/storm/kafka/PartitionManager.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/c9fb7a4b/external/storm-kafka/src/test/org/apache/storm/kafka/ZkCoordinatorTest.java ----------------------------------------------------------------------
