Interface | 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. |
OffsetsInitializerValidator |
Interface for validating
OffsetsInitializer with properties from KafkaSource . |
Class | Description |
---|---|
NoStoppingOffsetsInitializer |
An implementation of
OffsetsInitializer which does not initialize anything. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.