Package org.apache.storm.kafka.trident
Class TridentKafkaConsumerTopology
java.lang.Object
org.apache.storm.kafka.trident.TridentKafkaConsumerTopology
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic StormTopology
newTopology
(ITridentDataSource tridentSpout) Creates a new topology that prints inputs to stdout.
-
Field Details
-
LOG
protected static final org.slf4j.Logger LOG
-
-
Constructor Details
-
TridentKafkaConsumerTopology
public TridentKafkaConsumerTopology()
-
-
Method Details
-
newTopology
Creates a new topology that prints inputs to stdout.- Parameters:
tridentSpout
- The spout to use
-