Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/6083 Just my two cents, we've recently introduced a `DeserializationSchema` that uses Confluent Schema Registry to decode data. Could you reuse it rather than introduce a new one. The PR in which it was introduced is here: #5995
---