Uses of Class
org.apache.flink.cdc.connectors.kafka.sink.PartitionStrategy

Packages that use PartitionStrategy

Package	Description
org.apache.flink.cdc.connectors.kafka.sink

Uses of PartitionStrategy in org.apache.flink.cdc.connectors.kafka.sink

Fields in org.apache.flink.cdc.connectors.kafka.sink with type parameters of type PartitionStrategy

Modifier and Type	Field	Description
static ConfigOption<PartitionStrategy>	KafkaDataSinkOptions.PARTITION_STRATEGY

Methods in org.apache.flink.cdc.connectors.kafka.sink that return PartitionStrategy

Modifier and Type	Method	Description
static PartitionStrategy	PartitionStrategy.valueOf(String name)	Returns the enum constant of this type with the specified name.
static PartitionStrategy[]	PartitionStrategy.values()	Returns an array containing the constants of this enum type, in the order they are declared.

Constructors in org.apache.flink.cdc.connectors.kafka.sink with parameters of type PartitionStrategy

Constructor

Description

KafkaDataSink(org.apache.flink.connector.base.DeliveryGuarantee deliveryGuarantee, Properties kafkaProperties, PartitionStrategy partitionStrategy, java.time.ZoneId zoneId, org.apache.flink.api.common.serialization.SerializationSchema<Event> keySerialization, org.apache.flink.api.common.serialization.SerializationSchema<Event> valueSerialization, String topic, boolean addTableToHeaderEnabled, String customHeaders, String tableMapping)