add missing kafka dependency to flux-examples
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/8c9e6cee Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/8c9e6cee Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/8c9e6cee Branch: refs/heads/0.10.x-branch Commit: 8c9e6ceeafc1f50eebc519c8f03d5821813ee99b Parents: 9fad816 Author: P. Taylor Goetz <[email protected]> Authored: Fri May 8 15:35:11 2015 -0400 Committer: P. Taylor Goetz <[email protected]> Committed: Fri May 8 15:35:11 2015 -0400 ---------------------------------------------------------------------- .../org/apache/storm/flux/IntegrationTest.java | 2 -- external/flux/flux-examples/pom.xml | 20 ++++++++++++++++++++ 2 files changed, 20 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/8c9e6cee/external/flux/flux-core/src/test/java/org/apache/storm/flux/IntegrationTest.java ---------------------------------------------------------------------- diff --git a/external/flux/flux-core/src/test/java/org/apache/storm/flux/IntegrationTest.java b/external/flux/flux-core/src/test/java/org/apache/storm/flux/IntegrationTest.java index 5e17f5e..c5807f8 100644 --- a/external/flux/flux-core/src/test/java/org/apache/storm/flux/IntegrationTest.java +++ b/external/flux/flux-core/src/test/java/org/apache/storm/flux/IntegrationTest.java @@ -30,8 +30,6 @@ public class IntegrationTest { } } - - @Test public void testRunTopologySource() throws Exception { if(!skipTest) { http://git-wip-us.apache.org/repos/asf/storm/blob/8c9e6cee/external/flux/flux-examples/pom.xml ---------------------------------------------------------------------- diff --git a/external/flux/flux-examples/pom.xml b/external/flux/flux-examples/pom.xml index 571f302..e3996e5 100644 --- a/external/flux/flux-examples/pom.xml +++ b/external/flux/flux-examples/pom.xml @@ -52,6 +52,26 @@ <artifactId>storm-hbase</artifactId> <version>${project.version}</version> </dependency> + <dependency> + <groupId>org.apache.storm</groupId> + <artifactId>storm-kafka</artifactId> + <version>${project.version}</version> + </dependency> + <dependency> + <groupId>org.apache.kafka</groupId> + <artifactId>kafka_2.10</artifactId> + <version>0.8.1.1</version> + <exclusions> + <exclusion> + <groupId>org.apache.zookeeper</groupId> + <artifactId>zookeeper</artifactId> + </exclusion> + <exclusion> + <groupId>log4j</groupId> + <artifactId>log4j</artifactId> + </exclusion> + </exclusions> + </dependency> </dependencies> <build>
