From 501735699386aee34b241e2d6d5857a1c064df31 Mon Sep 17 00:00:00 2001 From: Colin Surprenant Date: Tue, 11 Jun 2013 15:08:51 -0400 Subject: [PATCH] issue #79 - fix dependencies doc for example kafka topology --- examples/simple/kafka_topology.rb | 27 +++++++++++++-------------- 1 file changed, 13 insertions(+), 14 deletions(-) diff --git a/examples/simple/kafka_topology.rb b/examples/simple/kafka_topology.rb index 8995cea..679f0f4 100644 --- a/examples/simple/kafka_topology.rb +++ b/examples/simple/kafka_topology.rb @@ -6,22 +6,21 @@ java_import 'storm.kafka.KafkaSpout' require 'red_storm' # the KafkaTopology obviously requires a Kafka server running, you can ajust the -# host and port below. +# host and port below. # # custom dependencies are required for the Kafka and Scala jars. put the following -# dependencies in the "Dependencies" file in the root of your RedStorm project: +# dependencies in the "ivy/topology_dependencies.xml" file in the root of your RedStorm project: # -# { -# :storm_artifacts => [ -# "storm:storm:0.8.1, transitive=true", -# ], -# :topology_artifacts => [ -# "org.jruby:jruby-complete:1.6.8, transitive=false", -# "org.scala-lang:scala-library:2.8.0, transitive=false", -# "storm:kafka:0.7.0-incubating, transitive=false", -# "storm:storm-kafka:0.8.0-wip4, transitive=false", -# ], -# } +# +# +# +# +# +# +# +# +# +# class KafkaTopology < RedStorm::SimpleTopology spout_config = SpoutConfig.new( @@ -37,7 +36,7 @@ class KafkaTopology < RedStorm::SimpleTopology end spout KafkaSpout, [spout_config] - + bolt SplitStringBolt do output_fields :word source KafkaSpout, :shuffle