Package | Description |
---|---|
org.apache.storm.kafka.spout |
Modifier and Type | Method and Description |
---|---|
KafkaSpoutConfig<K,V> |
KafkaSpoutConfig.Builder.build() |
protected KafkaSpoutConfig<String,String> |
KafkaSpoutTopologyMainWildcardTopics.getKafkaSpoutConfig(String bootstrapServers) |
protected KafkaSpoutConfig<String,String> |
KafkaSpoutTopologyMainNamedTopics.getKafkaSpoutConfig(String bootstrapServers) |
Modifier and Type | Method and Description |
---|---|
protected StormTopology |
KafkaSpoutTopologyMainWildcardTopics.getTopologyKafkaSpout(KafkaSpoutConfig<String,String> spoutConfig) |
protected StormTopology |
KafkaSpoutTopologyMainNamedTopics.getTopologyKafkaSpout(KafkaSpoutConfig<String,String> spoutConfig) |
Constructor and Description |
---|
KafkaSpout(KafkaSpoutConfig<K,V> kafkaSpoutConfig) |
Copyright © 2019 The Apache Software Foundation. All rights reserved.