Lian Jiang created FLINK-23160:
----------------------------------
Summary: upgrade kafka-schema-registry-client to 6.1.2 for
Flink-avro-confluent-registry
Key: FLINK-23160
URL: https://issues.apache.org/jira/browse/FLINK-23160
Project: Flink
Issue Type: Bug
Reporter: Lian Jiang
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 to
6.1.2 which has the fix? Meanwhile, does the Flink community have any
recommended workaround before dependency upgrade? Thanks for any help!
From Fabian -
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 you be
willing to work on this? A few things are still a bit unclear
i.e. are the newer confluent schema registry versions compatible with out Kafka
version (2.4.1).
Best,
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
