org.apache.flink.streaming.connectors.kafka.table

Class KafkaOptions.StartupOptions

java.lang.Object

org.apache.flink.streaming.connectors.kafka.table.KafkaOptions.StartupOptions

Enclosing class:

KafkaOptions

public static class KafkaOptions.StartupOptions
extends Object

Kafka startup options. *

Field Summary

Fields

Modifier and Type	Field and Description
Map<KafkaTopicPartition,Long>	specificOffsets
StartupMode	startupMode
long	startupTimestampMillis

Constructor Summary

Constructors

Constructor and Description
StartupOptions()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

startupMode

public StartupMode startupMode

specificOffsets

public Map<KafkaTopicPartition,Long> specificOffsets

startupTimestampMillis

public long startupTimestampMillis

Constructor Detail

StartupOptions

public StartupOptions()