Package | Description |
---|---|
org.apache.storm.kafka.spout | |
org.apache.storm.kafka.spout.internal | |
org.apache.storm.kafka.spout.trident |
Modifier and Type | Class and Description |
---|---|
class |
KafkaSpoutConfig<K,V>
KafkaSpoutConfig defines the required configuration to connect a consumer to a consumer group, as well as the subscribing topics.
|
Modifier and Type | Method and Description |
---|---|
abstract CommonKafkaSpoutConfig<K,V> |
CommonKafkaSpoutConfig.Builder.build() |
Modifier and Type | Class and Description |
---|---|
class |
KafkaTridentSpoutConfig<K,V>
Defines the required Kafka-related configuration for the Trident spouts.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.