(no subject)

[Georg Heiler]

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

[rmetzger0]

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 <[hidden email]> 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