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

Class KafkaDataSink

java.lang.Object

org.apache.flink.cdc.connectors.kafka.sink.KafkaDataSink

All Implemented Interfaces:

DataSink

public class KafkaDataSink
extends Object
implements DataSink

A DataSink for "Kafka" connector.

Constructor Summary

Constructors

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)

Method Summary

Modifier and Type	Method	Description
EventSinkProvider	getEventSinkProvider()	Get the EventSinkProvider for writing changed data to external systems.
MetadataApplier	getMetadataApplier()	Get the MetadataApplier for applying metadata changes to external systems.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.cdc.common.sink.DataSink

getDataChangeEventHashFunctionProvider, getDataChangeEventHashFunctionProvider

Constructor Detail

KafkaDataSink

public 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)

Method Detail

getEventSinkProvider

public EventSinkProvider getEventSinkProvider()

Description copied from interface: DataSink

Get the EventSinkProvider for writing changed data to external systems.

Specified by:

getEventSinkProvider in interface DataSink

getMetadataApplier

public MetadataApplier getMetadataApplier()

Description copied from interface: DataSink

Get the MetadataApplier for applying metadata changes to external systems.

Specified by:

getMetadataApplier in interface DataSink