@aljoscha, would be even better to have parameter object sort of wrapping Kafka ConsumerRecord instead of flat list of arguments (messageKey, message, topic, partition, offset, timestamp, headers,...) and pass it to deserialize? It feels more extensible approach - any futher changes in parameter object seems transparent for clients
[ Full content available at: https://github.com/apache/flink/pull/6105 ] This message was relayed via gitbox.apache.org for [email protected]
