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