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

Class Summary

Class	Description
KafkaDataSink	A DataSink for "Kafka" connector.
KafkaDataSinkFactory	A dummy DataSinkFactory to create KafkaDataSink.
KafkaDataSinkOptions	Options for KafkaDataSinkOptions.
KafkaMetaDataApplier	Supports KafkaDataSink to schema evolution.
KeySerializationFactory	Format factory for providing configured instances of SerializationSchema to convert Event to byte.
PipelineKafkaRecordSerializationSchema	A KafkaRecordSerializationSchema to serialize Event.

Enum Summary

Enum	Description
KeyFormat	Enum class for building SerializationSchema for ProducerRecord.
PartitionStrategy	Partition Strategy for sending ProducerRecord to kafka partition.