Found it. Using KeyedDeserializationSchema, I can get access to the partition, offset, key and value information.
From: John O Sent: Monday, August 20, 2018 3:15 PM To: user <user@flink.apache.org> Subject: Access to kafka partition per record I am consuming data from a kafka topic that has multiple partitions. I would like to keyby(record.partition). What would be the best way to get access to the partition information? Jo
