public class KafkaDataSinkOptions
extends Object

Fields
Modifier and Type	Field	Description
`static ConfigOption<Boolean>`	`DEBEZIUM_JSON_INCLUDE_SCHEMA_ENABLED`
`static String`	`DELIMITER_SELECTOR_TOPIC`
`static String`	`DELIMITER_TABLE_MAPPINGS`
`static ConfigOption<org.apache.flink.connector.base.DeliveryGuarantee>`	`DELIVERY_GUARANTEE`
`static ConfigOption<KeyFormat>`	`KEY_FORMAT`
`static ConfigOption<PartitionStrategy>`	`PARTITION_STRATEGY`
`static String`	`PROPERTIES_PREFIX`
`static ConfigOption<Boolean>`	`SINK_ADD_TABLEID_TO_HEADER_ENABLED`
`static ConfigOption<String>`	`SINK_CUSTOM_HEADER`
`static ConfigOption<String>`	`SINK_TABLE_ID_TO_TOPIC_MAPPING`
`static ConfigOption<String>`	`TOPIC`
`static ConfigOption<JsonSerializationType>`	`VALUE_FORMAT`

Method Summary
- Methods inherited from class java.lang.Object
  clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

public static final String PROPERTIES_PREFIX

public static final String DELIMITER_TABLE_MAPPINGS

public static final String DELIMITER_SELECTOR_TOPIC

public static final ConfigOption<org.apache.flink.connector.base.DeliveryGuarantee> DELIVERY_GUARANTEE

public static final ConfigOption<PartitionStrategy> PARTITION_STRATEGY

public static final ConfigOption<KeyFormat> KEY_FORMAT

public static final ConfigOption<JsonSerializationType> VALUE_FORMAT

public static final ConfigOption<String> TOPIC

public static final ConfigOption<Boolean> SINK_ADD_TABLEID_TO_HEADER_ENABLED

public static final ConfigOption<String> SINK_CUSTOM_HEADER

public static final ConfigOption<String> SINK_TABLE_ID_TO_TOPIC_MAPPING

public static final ConfigOption<Boolean> DEBEZIUM_JSON_INCLUDE_SCHEMA_ENABLED

Class KafkaDataSinkOptions