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

Class KeySerializationFactory

java.lang.Object

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

public class KeySerializationFactory
extends Object

Format factory for providing configured instances of SerializationSchema to convert Event to byte.

Constructor Summary

Constructors

Constructor	Description
KeySerializationFactory()

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.api.common.serialization.SerializationSchema<Event>	createSerializationSchema(org.apache.flink.configuration.ReadableConfig formatOptions, KeyFormat keyFormat, java.time.ZoneId zoneId)	Creates a configured instance of SerializationSchema to convert Event to byte.

Methods inherited from class java.lang.Object

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

Constructor Detail

KeySerializationFactory

public KeySerializationFactory()

Method Detail

createSerializationSchema

public static org.apache.flink.api.common.serialization.SerializationSchema<Event> createSerializationSchema(org.apache.flink.configuration.ReadableConfig formatOptions,
                                                                                                             KeyFormat keyFormat,
                                                                                                             java.time.ZoneId zoneId)

Creates a configured instance of SerializationSchema to convert Event to byte.