Hi, has someone experience setting up Avro Serde for primitive Java types in Flink, especially for Kafka key schemas? My current workaround is to explicitly define an Avro schema of type record (implementing

SpecificRecord

) which simply holds the value of the primitive. However, it would be much nicer, if I could directly use a default schema for such primitives without introducing my own type on the client side. I'm aware that for Kafka Streams there is a

PrimitiveAvroSerde

for exactly this purpose (https://github.com/confluentinc/schema-registry/blob/master/avro-serde/src/main/java/io/confluent/kafka/streams/serdes/avro/PrimitiveAvroSerde.java) and I'm wondering if something similar is possible for Flink and Avro?