Class and Description |
---|
KafkaPartitionSplit
A
SourceSplit for a Kafka partition. |
Class and Description |
---|
KafkaPartitionSplit
A
SourceSplit for a Kafka partition. |
Class and Description |
---|
KafkaPartitionSplit
A
SourceSplit for a Kafka partition. |
KafkaPartitionSplitState
This class extends KafkaPartitionSplit to track a mutable current offset.
|
Class and Description |
---|
KafkaPartitionSplit
A
SourceSplit for a Kafka partition. |
Class and Description |
---|
KafkaPartitionSplit
A
SourceSplit for a Kafka partition. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.