public class KafkaLogSerializationSchema extends Object implements org.apache.flink.streaming.connectors.kafka.KafkaSerializationSchema<SinkRecord>
KafkaRecordSerializationSchema
for the table in log store.Constructor and Description |
---|
KafkaLogSerializationSchema(String topic,
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.LogChangelogMode changelogMode) |
Modifier and Type | Method and Description |
---|---|
void |
open(org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext context) |
org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]> |
serialize(SinkRecord element,
Long timestamp) |
public KafkaLogSerializationSchema(String topic, @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.LogChangelogMode changelogMode)
public void open(org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext context) throws Exception
open
in interface org.apache.flink.streaming.connectors.kafka.KafkaSerializationSchema<SinkRecord>
Exception
public org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]> serialize(SinkRecord element, @Nullable Long timestamp)
serialize
in interface org.apache.flink.streaming.connectors.kafka.KafkaSerializationSchema<SinkRecord>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.