pyflink.datastream.connectors.kafka.KafkaRecordSerializationSchema

class KafkaRecordSerializationSchema(j_serialization_schema, topic_selector: Optional[pyflink.datastream.connectors.kafka.KafkaTopicSelector] = None)

A serialization schema which defines how to convert the stream record to kafka producer record.

New in version 1.16.0.

Methods

builder()

Creates a default schema builder to provide common building blocks i.e. key serialization, value serialization, topic selection.