Получение последней отметки времени сообщения в моей очереди Kafka - PullRequest
Новая
       35

Получение последней отметки времени сообщения в моей очереди Kafka

0 голосов
/ 19 декабря 2018

У меня есть Кафка 0.10.0, которая, если я правильно понимаю, добавляет временные метки ко всем сообщениям.В целях мониторинга я хочу вытащить метку времени самого нового сообщения для данной темы.Я не видел поле API для него ни в одной из библиотек Python, на которые смотрел.

1 Ответ

0 голосов
/ 19 декабря 2018

Не существует простого способа получить последнее сообщение Timestamp из тем Kafka.Но обходной путь - использование kafka customer и использование seek_to_end() для поиска наиболее доступного смещения для разделов.

consumer.seek_to_end()
for message in consumer:
    print(message.timestamp)

Вы можете сослаться на детали здесь:
https://kafka -python.readthedocs.io / en / master / apidoc / kafka.consumer.html # kafka.consumer.KafkaConsumer.seek_to_end

...