Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6083
@tillrohrmann
here is my two cents:
By converting the events to `String` and sending them to Kafka there is a
high risk to produce a `bad events` and we will lose the benifit of Schema
Registry to avoid this malformed events sent to the topic.
what you think about `AvroSerializationConfluentSchema` to Flink dist? If
we move this serialization code in Flink dist we can drop `kafka-avro`
dependencies from here.
but still if you think using `String` is ok I can update the PR and use
`String` instead of `AvroSerializationConfluentSchema`
---
