Package org.apache.flink.cdc.connectors.fluss.source

Class FlussDataSourceOptions

java.lang.Object

org.apache.flink.cdc.connectors.fluss.source.FlussDataSourceOptions

public class FlussDataSourceOptions
extends Object

Options for Fluss DataSource.

Field Summary

Fields

Modifier and Type	Field	Description
static ConfigOption<String>	BOOTSTRAP_SERVERS
static String	CLIENT_PROPERTIES_PREFIX
static ConfigOption<java.time.Duration>	SCAN_DISCOVERY_INTERVAL
static ConfigOption<java.time.Duration>	SCAN_KV_SNAPSHOT_LEASE_DURATION
static ConfigOption<String>	SCAN_KV_SNAPSHOT_LEASE_ID
static ConfigOption<String>	SCAN_STARTUP_MODE
static ConfigOption<String>	SCAN_STARTUP_TIMESTAMP
static String	TABLE_DISCOVERER_OPTIONS_PREFIX	Prefix shared by all table.discoverer.* keys.
static ConfigOption<String>	TABLE_DISCOVERER_TYPE

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

CLIENT_PROPERTIES_PREFIX

public static final String CLIENT_PROPERTIES_PREFIX

See Also:

Constant Field Values

BOOTSTRAP_SERVERS

public static final ConfigOption<String> BOOTSTRAP_SERVERS

TABLE_DISCOVERER_OPTIONS_PREFIX

public static final String TABLE_DISCOVERER_OPTIONS_PREFIX

Prefix shared by all table.discoverer.* keys. FlussDataSourceFactory excludes this prefix from strict option validation so that each TableDiscovererFactory implementation is free to declare its own namespaced options (e.g. table.discoverer.pattern, table.discoverer.jdbc.url) without being enumerated here.

See Also:

Constant Field Values

TABLE_DISCOVERER_TYPE

public static final ConfigOption<String> TABLE_DISCOVERER_TYPE

SCAN_STARTUP_MODE

public static final ConfigOption<String> SCAN_STARTUP_MODE

SCAN_STARTUP_TIMESTAMP

public static final ConfigOption<String> SCAN_STARTUP_TIMESTAMP

SCAN_DISCOVERY_INTERVAL

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

SCAN_KV_SNAPSHOT_LEASE_ID

public static final ConfigOption<String> SCAN_KV_SNAPSHOT_LEASE_ID

SCAN_KV_SNAPSHOT_LEASE_DURATION

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