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 y

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

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

Re: Avro and Kafka Schema Registry Client versions out of date

2020-07-09 Thread Arvid Heise
o, > > I noticed that even in Flink 1.11. Avro in flink-avro and the Kafka Schema > Registry client in flink-avro-confluent-registry are still at version 1.8.2 > and 4.1.0, respectively. > > Avro 1.9.2 brings a lot of improvements and bugfixes, in particular in > respect to logi

Fwd: Avro and Kafka Schema Registry Client versions out of date

2020-07-09 Thread Lucas Heimberg
Hello, I noticed that even in Flink 1.11. Avro in flink-avro and the Kafka Schema Registry client in flink-avro-confluent-registry are still at version 1.8.2 and 4.1.0, respectively. Avro 1.9.2 brings a lot of improvements and bugfixes, in particular in respect to logical types. The Kafka Schema

Fwd: Avro and Kafka Schema Registry Client versions out of date

2020-07-09 Thread Lucas Heimberg
Hello, I noticed that even in Flink 1.11. Avro in flink-avro and the Kafka Schema Registry client in flink-avro-confluent-registry are still at version 1.8.2 and 4.1.0, respectively. Avro 1.9.2 brings a lot of improvements and bugfixes, in particular in respect to logical types. The Kafka Schema

Re: Kafka Schema registry

2020-01-14 Thread aj
d from Schema Registry and transformed to a statically >provided( either through >ConfluentRegistryAvroDeserializationSchema.forGeneric(...) or >ConfluentRegistryAvroDeserializationSchema.forSpecific(...)). > > > On Wed, Sep 11, 2019 at 1:48 PM Lasse Nedergaard < > lassenederga...@gmai

Re: Kafka Schema registry

2019-09-12 Thread Lasse Nedergaard
atically provided( either through > ConfluentRegistryAvroDeserializationSchema.forGeneric(...) or > ConfluentRegistryAvroDeserializationSchema.forSpecific(...)). > >> On Wed, Sep 11, 2019 at 1:48 PM Lasse Nedergaard >> wrote: >> Hi. >> Do Flink have out of the Box Support for Kaf

Re: Kafka Schema registry

2019-09-12 Thread Elias Levy
hrough ConfluentRegistryAvroDeserializationSchema.forGeneric(...) or ConfluentRegistryAvroDeserializationSchema.forSpecific(...)). On Wed, Sep 11, 2019 at 1:48 PM Lasse Nedergaard wrote: > Hi. > Do Flink have out of the Box Support for Kafka Schema registry for both > sources and sinks? > If not, does anyone knows about a

Kafka Schema registry

2019-09-11 Thread Lasse Nedergaard
Hi. Do Flink have out of the Box Support for Kafka Schema registry for both sources and sinks? If not, does anyone knows about a implementation we can build on so we can help make it general available in a future release. Med venlig hilsen / Best regards Lasse Nedergaard