Получить дату последнего изменения темы Кафки

Question

Я знаю, что возможно получить последнее смещение kafka, но возможно ли получить метку времени последнего изменения темы kafka с помощью сценариев консоли kafka?

Я видел этот вопрос Kafka: Как узнать время последнего изменения темы, т.е. последнее сообщение, добавленное в любой раздел темы , но без реального ответа на мой вопрос.

Answer 1

Вы не можете получить метку времени прямо из сценария.Вместо этого вы можете увидеть метку времени, используя скрипт консольного потребителя.Он показывает CreateTime для сообщения. Как уже упоминалось @Sreekiran, используйте свойство "print.timestamp", как показано ниже:

ncsv@ubuntu:/data/softwares/kafka_2.11-2.0.0$ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testJsonTopic1 --property print.timestamp=true --from-beginning
CreateTime:1544445041225        {"id": "9","name": "wis"}
CreateTime:1544518616282        {"id": "19","name": "wes"}
CreateTime:1544520723808        {"id": "1","name": "test1"}
CreateTime:1544446690508        {"id": "9","name": "wes"}
CreateTime:1544445375123        {"id": "9","name": "wes"}
CreateTime:1544520388080        {"id": "20","name": "test1"}

Это покажет время, когда событие было записано в кластере.

Answer 2

Добавьте это к текущей команде --property print.timestamp=true Это напечатает метку времени CreateTime:1544706749268.