| Package | Description |
|---|---|
| org.apache.heron.kafka.spout | |
| org.apache.heron.kafka.spout.internal |
| 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() |
Copyright © 2020 The Apache Software Foundation. All rights reserved.