@alexeyt820 I think it is not easily possible to resolve the conflicts between this PR and #6105, which also touches the `KeyedDeserializationSchema` and follows a somewhat different approach.
I'm also not found of wrapping the Kafka record bytes into `Record`; that basically always ties deserialization of the bytes with access to other meta information, and makes it hard to reuse some already existing deserialization formats such as `AvroDeserializationSchema`. Is it ok if I open a new PR that is based on this one and #6105, and see what I come up with? I might not be able to do that this week, but I can do that as soon as I finish with what I'm currently busy with. cc @FredTing would that also be ok for you? [ Full content available at: https://github.com/apache/flink/pull/6615 ] This message was relayed via gitbox.apache.org for [email protected]
