pyflink.datastream.connectors.kafka.KafkaRecordSerializationSchema#
- class KafkaRecordSerializationSchema(j_serialization_schema, topic_selector: Optional[pyflink.datastream.connectors.kafka.KafkaTopicSelector] = None)[source]#
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.