org.apache.paimon.flink.kafka

Class KafkaLogSinkProvider

java.lang.Object

org.apache.paimon.flink.kafka.KafkaLogSinkProvider

All Implemented Interfaces:

Serializable, LogSinkProvider

public class KafkaLogSinkProvider
extends Object
implements LogSinkProvider

A Kafka LogSinkProvider.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KafkaLogSinkProvider(String topic, Properties properties, org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> primaryKeySerializer, org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> valueSerializer, CoreOptions.LogConsistency consistency, CoreOptions.LogChangelogMode changelogMode)

Method Summary

Modifier and Type	Method and Description
LogSinkFunction	createSink() Creates a LogSinkFunction instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaLogSinkProvider

public KafkaLogSinkProvider(String topic,
                            Properties properties,
                            @Nullable
                            org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> primaryKeySerializer,
                            org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> valueSerializer,
                            CoreOptions.LogConsistency consistency,
                            CoreOptions.LogChangelogMode changelogMode)

Method Detail

createSink

public LogSinkFunction createSink()

Description copied from interface: LogSinkProvider

Creates a LogSinkFunction instance.

Specified by:

createSink in interface LogSinkProvider