Package | Description |
---|---|
org.apache.storm.kafka.spout | |
org.apache.storm.kafka.spout.internal | |
org.apache.storm.kafka.spout.trident | |
org.apache.storm.kafka.trident |
Modifier and Type | Method and Description |
---|---|
KafkaSpoutConfig<K,V> |
KafkaSpoutConfig.Builder.build() |
Constructor and Description |
---|
KafkaSpout(KafkaSpoutConfig<K,V> kafkaSpoutConfig) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.consumer.KafkaConsumer<K,V> |
KafkaConsumerFactoryDefault.createConsumer(KafkaSpoutConfig<K,V> kafkaSpoutConfig) |
org.apache.kafka.clients.consumer.KafkaConsumer<K,V> |
KafkaConsumerFactory.createConsumer(KafkaSpoutConfig<K,V> kafkaSpoutConfig) |
Constructor and Description |
---|
KafkaTridentSpoutManager(KafkaSpoutConfig<K,V> kafkaSpoutConfig)
Create a KafkaConsumer manager for the trident spout.
|
KafkaTridentSpoutOpaque(KafkaSpoutConfig<K,V> conf) |
Modifier and Type | Method and Description |
---|---|
protected KafkaSpoutConfig<String,String> |
TridentKafkaClientWordCountNamedTopics.newKafkaSpoutConfig() |
protected KafkaSpoutConfig<String,String> |
TridentKafkaClientWordCountWildcardTopics.newKafkaSpoutConfig() |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.