Как получить временную метку Кафки для записи во Флинке?

Question

У меня есть приложение Flink, которое использует FlinkKafkaConsumer.

Я заинтересован в получении Kafka метки времени для данного record/offset, используя KeyedDeserializationSchema. Похоже, что тема, раздел, смещение и сообщение доступны.

Как получить метку времени?

Answer 1

Вы можете просто использовать ConsumerRecord.timestamp() - отметку времени в миллисекундах с начала эпохи (полночь 1 января 1970 года (UTC)). Тип временной отметки указывается в timestampType ().