Блог

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

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

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

Смотрите раздел «Конфигурации темы» в документации.