[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 PR has been updated!
    I had to do some changes:
    - map `User` object to `String` in `TestAvroConsumerConfluent` class
    - use `read_messages_from_kafka` instead of `read_messages_from_kafka_avro` 
for vaidation as the events are `String` not `Avro` anymore
    - removed `kafka-avro` dependency
    
    When we add `AvroSerializationConfluentSchema` to Flink, I will update the 
test as we discussed.


---