Uses of Interface
org.apache.flink.connector.kafka.sink.KafkaRecordSerializationSchema.KafkaSinkContext

Packages that use KafkaRecordSerializationSchema.KafkaSinkContext

Package	Description
org.apache.flink.connector.kafka.sink

Uses of KafkaRecordSerializationSchema.KafkaSinkContext in org.apache.flink.connector.kafka.sink

Classes in org.apache.flink.connector.kafka.sink that implement KafkaRecordSerializationSchema.KafkaSinkContext

Modifier and Type	Class and Description
class	DefaultKafkaSinkContext Context providing information to assist constructing a ProducerRecord.

Methods in org.apache.flink.connector.kafka.sink with parameters of type KafkaRecordSerializationSchema.KafkaSinkContext

Modifier and Type	Method and Description
default void	KafkaRecordSerializationSchema.open(SerializationSchema.InitializationContext context, KafkaRecordSerializationSchema.KafkaSinkContext sinkContext) Initialization method for the schema.
org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]>	KafkaRecordSerializationSchema.serialize(T element, KafkaRecordSerializationSchema.KafkaSinkContext context, Long timestamp) Serializes given element and returns it as a ProducerRecord.