For this, I would await the outcome of #6577. If we end up only having one "modern" Kafka connector we might just pass through the `ConsumerRecord`. Otherwise we might have to do some wrapping.
[ Full content available at: https://github.com/apache/flink/pull/6615 ] This message was relayed via gitbox.apache.org for [email protected]
