pyflink.datastream.connectors.kafka.KafkaOffsetResetStrategy#

class KafkaOffsetResetStrategy(value)[source]#

Corresponding to Java org.apache.kafka.client.consumer.OffsetResetStrategy class.

New in version 1.16.0.