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

Class KafkaConnectorOptions

java.lang.Object

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

@PublicEvolving
public class KafkaConnectorOptions
extends Object

Options for the Kafka connector.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaConnectorOptions.ScanBoundedMode Bounded mode for the Kafka consumer, see SCAN_BOUNDED_MODE.
static class	KafkaConnectorOptions.ScanStartupMode Startup mode for the Kafka consumer, see SCAN_STARTUP_MODE.
static class	KafkaConnectorOptions.ValueFieldsStrategy Strategies to derive the data type of a value format by considering a key format.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<DeliveryGuarantee>	DELIVERY_GUARANTEE
static ConfigOption<List<String>>	KEY_FIELDS
static ConfigOption<String>	KEY_FIELDS_PREFIX
static ConfigOption<String>	KEY_FORMAT
static ConfigOption<String>	PROPS_BOOTSTRAP_SERVERS
static ConfigOption<String>	PROPS_GROUP_ID
static ConfigOption<KafkaConnectorOptions.ScanBoundedMode>	SCAN_BOUNDED_MODE
static ConfigOption<String>	SCAN_BOUNDED_SPECIFIC_OFFSETS
static ConfigOption<Long>	SCAN_BOUNDED_TIMESTAMP_MILLIS
static ConfigOption<KafkaConnectorOptions.ScanStartupMode>	SCAN_STARTUP_MODE
static ConfigOption<String>	SCAN_STARTUP_SPECIFIC_OFFSETS
static ConfigOption<Long>	SCAN_STARTUP_TIMESTAMP_MILLIS
static ConfigOption<java.time.Duration>	SCAN_TOPIC_PARTITION_DISCOVERY
static ConfigOption<java.time.Duration>	SINK_BUFFER_FLUSH_INTERVAL
static ConfigOption<Integer>	SINK_BUFFER_FLUSH_MAX_ROWS
static ConfigOption<Integer>	SINK_PARALLELISM
static ConfigOption<String>	SINK_PARTITIONER
static ConfigOption<List<String>>	TOPIC
static ConfigOption<String>	TOPIC_PATTERN
static ConfigOption<String>	TRANSACTIONAL_ID_PREFIX
static ConfigOption<KafkaConnectorOptions.ValueFieldsStrategy>	VALUE_FIELDS_INCLUDE
static ConfigOption<String>	VALUE_FORMAT

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

KEY_FORMAT

public static final ConfigOption<String> KEY_FORMAT

VALUE_FORMAT

public static final ConfigOption<String> VALUE_FORMAT

KEY_FIELDS

public static final ConfigOption<List<String>> KEY_FIELDS

VALUE_FIELDS_INCLUDE

public static final ConfigOption<KafkaConnectorOptions.ValueFieldsStrategy> VALUE_FIELDS_INCLUDE

KEY_FIELDS_PREFIX

public static final ConfigOption<String> KEY_FIELDS_PREFIX

SINK_PARALLELISM

public static final ConfigOption<Integer> SINK_PARALLELISM

TOPIC

public static final ConfigOption<List<String>> TOPIC

TOPIC_PATTERN

public static final ConfigOption<String> TOPIC_PATTERN

PROPS_BOOTSTRAP_SERVERS

public static final ConfigOption<String> PROPS_BOOTSTRAP_SERVERS

PROPS_GROUP_ID

public static final ConfigOption<String> PROPS_GROUP_ID

SCAN_STARTUP_MODE

public static final ConfigOption<KafkaConnectorOptions.ScanStartupMode> SCAN_STARTUP_MODE

SCAN_BOUNDED_MODE

public static final ConfigOption<KafkaConnectorOptions.ScanBoundedMode> SCAN_BOUNDED_MODE

SCAN_STARTUP_SPECIFIC_OFFSETS

public static final ConfigOption<String> SCAN_STARTUP_SPECIFIC_OFFSETS

SCAN_BOUNDED_SPECIFIC_OFFSETS

public static final ConfigOption<String> SCAN_BOUNDED_SPECIFIC_OFFSETS

SCAN_STARTUP_TIMESTAMP_MILLIS

public static final ConfigOption<Long> SCAN_STARTUP_TIMESTAMP_MILLIS

SCAN_BOUNDED_TIMESTAMP_MILLIS

public static final ConfigOption<Long> SCAN_BOUNDED_TIMESTAMP_MILLIS

SCAN_TOPIC_PARTITION_DISCOVERY

public static final ConfigOption<java.time.Duration> SCAN_TOPIC_PARTITION_DISCOVERY

SINK_PARTITIONER

public static final ConfigOption<String> SINK_PARTITIONER

SINK_BUFFER_FLUSH_MAX_ROWS

public static final ConfigOption<Integer> SINK_BUFFER_FLUSH_MAX_ROWS

SINK_BUFFER_FLUSH_INTERVAL

public static final ConfigOption<java.time.Duration> SINK_BUFFER_FLUSH_INTERVAL

DELIVERY_GUARANTEE

public static final ConfigOption<DeliveryGuarantee> DELIVERY_GUARANTEE

TRANSACTIONAL_ID_PREFIX

public static final ConfigOption<String> TRANSACTIONAL_ID_PREFIX