Class and Description |
---|
OffsetsInitializer
An interface for users to specify the starting / stopping offset of a
KafkaPartitionSplit . |
Class and Description |
---|
OffsetsInitializer
An interface for users to specify the starting / stopping offset of a
KafkaPartitionSplit . |
OffsetsInitializer.PartitionOffsetsRetriever
An interface that provides necessary information to the
OffsetsInitializer to get the
initial offsets of the Kafka partitions. |
Class and Description |
---|
OffsetsInitializer
An interface for users to specify the starting / stopping offset of a
KafkaPartitionSplit . |
OffsetsInitializer.PartitionOffsetsRetriever
An interface that provides necessary information to the
OffsetsInitializer to get the
initial offsets of the Kafka partitions. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.