Package org.apache.storm.kafka.spout
Class KafkaSpoutTopologyMainNamedTopics
java.lang.Object
org.apache.storm.kafka.spout.KafkaSpoutTopologyMainNamedTopics
- Direct Known Subclasses:
- KafkaSpoutTopologyMainWildcardTopics
This example sets up 3 topologies to put data in Kafka via the KafkaBolt,
 and shows how to set up a topology that reads from some Kafka topics using the KafkaSpout.
- 
Field SummaryFields
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionprotected Configprotected KafkaSpoutConfig<String,String> getKafkaSpoutConfig(String bootstrapServers) protected KafkaSpoutRetryServiceprotected StormTopologygetTopologyKafkaSpout(KafkaSpoutConfig<String, String> spoutConfig) static voidprotected void
- 
Field Details- 
TOPIC_0- See Also:
 
- 
TOPIC_1- See Also:
 
- 
TOPIC_2- See Also:
 
 
- 
- 
Constructor Details- 
KafkaSpoutTopologyMainNamedTopicspublic KafkaSpoutTopologyMainNamedTopics()
 
- 
- 
Method Details