Mohammad Hossein Gerami created FLINK-18800: -----------------------------------------------
Summary: Avro serialization schema doesn't support Kafka key/value serialization Key: FLINK-18800 URL: https://issues.apache.org/jira/browse/FLINK-18800 Project: Flink Issue Type: Improvement Components: API / Type Serialization System, Connectors / Kafka, Formats (JSON, Avro, Parquet, ORC, SequenceFile) Affects Versions: 1.11.1, 1.11.0 Reporter: Mohammad Hossein Gerami {color:#ff8b00}AvroSerializationSchema{color} and {color:#ff8b00}ConfluentRegistryAvroSerializationSchema{color} doesn't support Kafka key/value serialization. I implemented a custom Avro serialization schema for solving this problem. -- This message was sent by Atlassian Jira (v8.3.4#803005)