You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2014/04/21 21:44:39 UTC
[40/50] [abbrv] git commit: Merge branch 'master' of
github.com:wurstmeister/storm-kafka-0.8-plus
Merge branch 'master' of github.com:wurstmeister/storm-kafka-0.8-plus
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/adab172a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/adab172a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/adab172a
Branch: refs/heads/master
Commit: adab172a7d5621eb4497f9ec511f43c04991b2e3
Parents: e1b6fb4 c8c04a6
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Wed Apr 9 09:32:23 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Wed Apr 9 09:32:23 2014 -0400
----------------------------------------------------------------------
CHANGELOG.md | 3 +
README.md | 10 +-
src/jvm/storm/kafka/KafkaUtils.java | 35 ++++-
src/jvm/storm/kafka/PartitionManager.java | 34 ++---
src/jvm/storm/kafka/StaticCoordinator.java | 7 +-
src/jvm/storm/kafka/ZkCoordinator.java | 35 +++--
.../storm/kafka/DynamicBrokersReaderTest.java | 2 +
src/test/storm/kafka/KafkaTestBroker.java | 1 +
src/test/storm/kafka/KafkaUtilsTest.java | 40 ++++++
src/test/storm/kafka/TestUtils.java | 20 +++
src/test/storm/kafka/ZkCoordinatorTest.java | 130 +++++++++++++++++++
src/test/storm/kafka/bolt/KafkaBoltTest.java | 1 +
12 files changed, 270 insertions(+), 48 deletions(-)
----------------------------------------------------------------------