storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [2/3] storm git commit: Merge branch 'kafka_spout_no_dup_on_leader_changes_1_x' of https://github.com/ernisv/storm into STORM-2296-1.x-merge
Date Fri, 03 Feb 2017 23:25:10 GMT
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 <kabhwan@gmail.com>
Authored: Sat Feb 4 08:00:47 2017 +0900
Committer: Jungtaek Lim <kabhwan@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
----------------------------------------------------------------------


Mime
View raw message