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 Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier 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
-
KafkaSpoutTopologyMainNamedTopics
public KafkaSpoutTopologyMainNamedTopics()
-
-
Method Details