issue #79 - fix dependencies doc for example kafka topology

This commit is contained in:
Colin Surprenant 2013-06-11 15:08:51 -04:00
parent cee9578349
commit 5017356993
1 changed files with 13 additions and 14 deletions

View File

@ -6,22 +6,21 @@ java_import 'storm.kafka.KafkaSpout'
require 'red_storm' require 'red_storm'
# the KafkaTopology obviously requires a Kafka server running, you can ajust the # 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 # 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:
# #
# { # <?xml version="1.0"?>
# :storm_artifacts => [ # <ivy-module version="2.0">
# "storm:storm:0.8.1, transitive=true", # <info organisation="redstorm" module="topology-deps"/>
# ], # <dependencies>
# :topology_artifacts => [ # <dependency org="org.jruby" name="jruby-core" rev="1.7.3" conf="default" transitive="true"/>
# "org.jruby:jruby-complete:1.6.8, transitive=false", # <dependency org="org.scala-lang" name="scala-library" rev="2.8.0" conf="default" transitive="false"/>
# "org.scala-lang:scala-library:2.8.0, transitive=false", # <dependency org="storm" name="kafka" rev="0.7.0-incubating" conf="default" transitive="false"/>
# "storm:kafka:0.7.0-incubating, transitive=false", # <dependency org="storm" name="storm-kafka" rev="0.8.0-wip4" conf="default" transitive="false"/>
# "storm:storm-kafka:0.8.0-wip4, transitive=false", # </dependencies>
# ], # </ivy-module>
# }
class KafkaTopology < RedStorm::SimpleTopology class KafkaTopology < RedStorm::SimpleTopology
spout_config = SpoutConfig.new( spout_config = SpoutConfig.new(
@ -37,7 +36,7 @@ class KafkaTopology < RedStorm::SimpleTopology
end end
spout KafkaSpout, [spout_config] spout KafkaSpout, [spout_config]
bolt SplitStringBolt do bolt SplitStringBolt do
output_fields :word output_fields :word
source KafkaSpout, :shuffle source KafkaSpout, :shuffle