Re:

[Robert Metzger <rm...@apache.org>]

Hi,
For the others checking the user@ mailing list: It seems this problem will
get resolved through [1].

[1] https://issues.apache.org/jira/browse/FLINK-18478

On Mon, Jun 29, 2020 at 1:23 PM Georg Heiler <ge...@gmail.com>
wrote:

> Hi,
>
> I try to use the confluent schema registry in an interactive Flink Scala
> shell.
>
> My problem is trying to initialize the serializer from the
> ConfluentRegistryAvroDeserializationSchema fails:
>
> ```scala
> val serializer = ConfluentRegistryAvroDeserializationSchema.forSpecific[Tweet](classOf[Tweet], schemaRegistryUrl)
> error: type arguments [Tweet] conform to the bounds of none of the overloaded alternatives of
> value forSpecific: [T <: org.apache.avro.specific.SpecificRecord](x$1: Class[T], x$2: String, x$3: Int)org.apache.flink.formats.avro.registry.confluent.ConfluentRegistryAvroDeserializationSchema[T] <and> [T <: org.apache.avro.specific.SpecificRecord](x$1: Class[T], x$2: String)org.apache.flink.formats.avro.registry.confluent.ConfluentRegistryAvroDeserializationSchema[T]
> ```
>
> please see
>
> https://stackoverflow.com/questions/62637009/flink-use-confluent-schema-registry-for-avro-serde
> for details how the shell was set up and which additional JARs were loaded
>
> Best,
> Georg
>