[GitHub] flink issue #6083: [FLINK-8983] End-to-end test: Confluent schema registry

[medcv]

Github user medcv commented on the issue:

    https://github.com/apache/flink/pull/6083
  
    @tillrohrmann I made the changes and used 
`ConfluentRegistryAvroDeserializationSchema` for the Deserializations.  
    I still using `AvroSerializationConfluentSchema` as we need to compare each 
income `Event` with `Schema` before sending the data to Kafka and use the 
schema registry concept to have a full end2end test.
    We might need to `AvroSerializationConfluentSchema` also to the Flink dist. 


---