Class | Description |
---|---|
KafkaSourceEnumerator |
The enumerator class for Kafka source.
|
KafkaSourceEnumerator.PartitionOffsetsRetrieverImpl |
The implementation for offsets retriever with a consumer and an admin client.
|
KafkaSourceEnumState |
The state of Kafka source enumerator.
|
KafkaSourceEnumStateSerializer |
The
Serializer for the enumerator
state of Kafka source. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.