Hi,

I am using ConfluentRegistryAvroSerializationSchema and blocked by a bug
mentioned by https://github.com/confluentinc/schema-registry/issues/1352
and the final fix is done by
https://github.com/confluentinc/schema-registry/pull/1839. I did not find
any easy workaround.

Flink-avro-confluent-registry (
https://mvnrepository.com/artifact/org.apache.flink/flink-avro-confluent-registry)
still use 5.5.2 kafka-schema-registry-client
<https://mvnrepository.com/artifact/io.confluent/kafka-schema-registry-client>
which does not have this fix. Could the next Flink upgrade this dependency
of 6.1.2 which has the fix? Meanwhile, does the Flink community have any
recommended workaround before dependency upgrade? Thanks for any help!

Reply via email to