pyflink.datastream.connectors.kafka.KafkaOffsetsInitializer

class KafkaOffsetsInitializer(j_initializer: JavaObject)

An interface for users to specify the starting / stopping offset of a KafkaPartitionSplit.

New in version 1.16.0.

Methods

committed_offsets([offset_reset_strategy])	Get an KafkaOffsetsInitializer which initializes the offsets to the committed offsets.
earliest()	Get an KafkaOffsetsInitializer which initializes the offsets to the earliest available offsets of each partition.
latest()	Get an KafkaOffsetsInitializer which initializes the offsets to the latest offsets of each partition.
offsets(offsets[, offset_reset_strategy])	Get an KafkaOffsetsInitializer which initializes the offsets to the specified offsets.
timestamp(timestamp)	Get an KafkaOffsetsInitializer which initializes the offsets in each partition so that the initialized offset is the offset of the first record whose record timestamp is greater than or equals the give timestamp.