Получить время, когда сообщение достигло Кафки

Question

В метке времени в метафайле сообщения для Kafka указано время, когда производитель Kafka отправил сообщение, но моя цель - извлечь время, когда сообщение достигло кластера Kafka.Есть ли способ извлечь это?

Answer 1

По умолчанию Kafka будет использовать временную метку, предоставленную производителем.

Однако вы также можете заставить Kafka обновлять временную метку, когда она записывает запись в журнал, установив message.timestamp.type в LogAppendTime на вашемtopic.

См. раздел настроек темы в документации.