Hello, I need to consume data from a avro-confluent topic created by KSQL using KSQL's atomic key format. The key is a primitive "int" no record hence I can't deserialize it with flink using the avro-confluent key format. Does anyone of you ever encountered this problem and how did you solve it? Thanks a lot for your help!

(FWIW, you might wanna also ask this over on the Confluent Community Slack where you might find more folk using KSQL)

Will do thanks. The thing is that Confluent Cloud FlinkSQL actually can handle this according to its documentation.