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:48 UTC
[49/50] [abbrv] git commit: Merge branch 'storm-kafka-module'
Merge branch 'storm-kafka-module'
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/98265c75
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/98265c75
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/98265c75
Branch: refs/heads/master
Commit: 98265c75aae72f535eb2beb9b97b68db44adb0ab
Parents: 6cc9bfe ae728f8
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Mon Apr 21 15:38:02 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Mon Apr 21 15:38:02 2014 -0400
----------------------------------------------------------------------
external/storm-kafka/CHANGELOG.md | 13 +
external/storm-kafka/README.md | 25 ++
external/storm-kafka/pom.xml | 138 ++++++++++
.../storm-kafka/src/jvm/storm/kafka/Broker.java | 80 ++++++
.../src/jvm/storm/kafka/BrokerHosts.java | 25 ++
.../jvm/storm/kafka/DynamicBrokersReader.java | 145 ++++++++++
.../kafka/DynamicPartitionConnections.java | 94 +++++++
.../jvm/storm/kafka/FailedFetchException.java | 29 ++
.../src/jvm/storm/kafka/KafkaConfig.java | 50 ++++
.../src/jvm/storm/kafka/KafkaError.java | 43 +++
.../src/jvm/storm/kafka/KafkaSpout.java | 190 +++++++++++++
.../src/jvm/storm/kafka/KafkaUtils.java | 235 ++++++++++++++++
.../src/jvm/storm/kafka/KeyValueScheme.java | 28 ++
.../kafka/KeyValueSchemeAsMultiScheme.java | 36 +++
.../src/jvm/storm/kafka/Partition.java | 64 +++++
.../jvm/storm/kafka/PartitionCoordinator.java | 26 ++
.../src/jvm/storm/kafka/PartitionManager.java | 241 +++++++++++++++++
.../src/jvm/storm/kafka/SpoutConfig.java | 36 +++
.../src/jvm/storm/kafka/StaticCoordinator.java | 48 ++++
.../src/jvm/storm/kafka/StaticHosts.java | 38 +++
.../storm/kafka/StaticPartitionConnections.java | 52 ++++
.../jvm/storm/kafka/StringKeyValueScheme.java | 37 +++
.../src/jvm/storm/kafka/StringScheme.java | 46 ++++
.../src/jvm/storm/kafka/ZkCoordinator.java | 112 ++++++++
.../src/jvm/storm/kafka/ZkHosts.java | 36 +++
.../src/jvm/storm/kafka/ZkState.java | 116 ++++++++
.../src/jvm/storm/kafka/bolt/KafkaBolt.java | 89 ++++++
.../jvm/storm/kafka/trident/Coordinator.java | 50 ++++
.../storm/kafka/trident/DefaultCoordinator.java | 31 +++
.../trident/GlobalPartitionInformation.java | 99 +++++++
.../storm/kafka/trident/IBatchCoordinator.java | 26 ++
.../jvm/storm/kafka/trident/IBrokerReader.java | 25 ++
.../src/jvm/storm/kafka/trident/MaxMetric.java | 40 +++
.../kafka/trident/OpaqueTridentKafkaSpout.java | 59 ++++
.../storm/kafka/trident/StaticBrokerReader.java | 36 +++
.../trident/TransactionalTridentKafkaSpout.java | 58 ++++
.../storm/kafka/trident/TridentKafkaConfig.java | 37 +++
.../kafka/trident/TridentKafkaEmitter.java | 269 +++++++++++++++++++
.../jvm/storm/kafka/trident/ZkBrokerReader.java | 62 +++++
.../storm/kafka/DynamicBrokersReaderTest.java | 155 +++++++++++
.../src/test/storm/kafka/KafkaErrorTest.java | 39 +++
.../src/test/storm/kafka/KafkaTestBroker.java | 58 ++++
.../src/test/storm/kafka/KafkaUtilsTest.java | 221 +++++++++++++++
.../storm/kafka/StringKeyValueSchemeTest.java | 38 +++
.../src/test/storm/kafka/TestUtils.java | 20 ++
.../src/test/storm/kafka/ZkCoordinatorTest.java | 130 +++++++++
.../test/storm/kafka/bolt/KafkaBoltTest.java | 171 ++++++++++++
pom.xml | 1 +
storm-dist/binary/src/main/assembly/binary.xml | 19 ++
49 files changed, 3716 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/98265c75/pom.xml
----------------------------------------------------------------------