Package org.apache.storm.kafka.trident
Class TridentKafkaClientTopologyNamedTopics
java.lang.Object
org.apache.storm.kafka.trident.TridentKafkaClientTopologyNamedTopics
- Direct Known Subclasses:
TridentKafkaClientTopologyWildcardTopics
This example sets up a few topologies to put random strings in Kafka topics via the KafkaBolt,
and shows how to set up a Trident topology that reads from some Kafka topics using the KafkaSpout.
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic void
protected KafkaTridentSpoutConfig<String,
String> newKafkaSpoutConfig
(String bootstrapServers) protected void
-
Constructor Details
-
TridentKafkaClientTopologyNamedTopics
public TridentKafkaClientTopologyNamedTopics()
-
-
Method Details
-
newKafkaSpoutConfig
-
main
- Throws:
Exception
-
run
protected void run(String[] args) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, InterruptedException
-