Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6259
@dawidwys I update the PR, please review
the usage would be like this
` ConfluentRegistryAvroSerializationSchema.forSpecific(User.class, subject,
schemaRegistryUrl)`
as Confluent needs "subject" to fetch the Schema info. Now
`ConfluentRegistryAvroSerializationSchema` uses "subject" directly instated on
`topic + "-value"`.---
