Re: upgrade kafka-schema-registry-client to 6.1.2 for Flink-avro-confluent-registry

2021-06-25 Thread Lian Jiang
Thanks Fabian. [FLINK-23160] upgrade kafka-schema-registry-client to 6.1.2 for Flink-avro-confluent-registry - ASF JIRA (apache.org) <https://issues.apache.org/jira/browse/FLINK-23160> is created. I will create a private build Flink to try out the fix. If it goes well, I can contribut

Re: upgrade kafka-schema-registry-client to 6.1.2 for Flink-avro-confluent-registry

2021-06-25 Thread Fabian Paul
Hi, Thanks for bringing this up. It looks to me like something we definitely want to fix. Unfortunately, I also do not see an easy workaround besides building your own flink-avro-confluent-registry and bumping the dependency. Can you create a JIRA ticket for bumping the dependencies and would

upgrade kafka-schema-registry-client to 6.1.2 for Flink-avro-confluent-registry

2021-06-24 Thread Lian Jiang
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.