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 <georg.kf.hei...@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 >
