T- the type of values being serialized
@PublicEvolving public interface KafkaSerializationSchema<T> extends Serializable
KafkaSerializationSchemadefines how to serialize values of type
Please also implement
KafkaContextAware if your serialization schema needs
about the available partitions and the number of parallel subtasks along with the subtask ID on
which the Kafka Producer is running.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.