Hi, I have a flink app which uses the FlinkKafkaConsumer. I am interested in retrieving the Kafka timestamp for a given record/offset using the *KeyedDeserializationSchema* which provides topic, partition, offset and message.
How can the timestamp be obtained through this interface? Thank you
