python - 获取我的 Kafka 队列中的最新消息时间戳

Question

我有 Kafka 0.10.0，如果我理解正确的话，它会为所有消息添加时间戳。出于监控目的，我想提取给定主题的最新消息的时间戳。我在我查看过的任何 Python 库中都没有看到它的 API 字段。

Answer 1

没有直接的方法可以从 Kafka 主题获取最新消息时间戳。但解决方法是使用 kafka 消费者，并使用 seek_to_end() 来寻找分区最可用的偏移量。

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

您可以在此处引用详细信息:
https://kafka-python.readthedocs.io/en/master/apidoc/KafkaConsumer.html#kafka.KafkaConsumer.seek_to_end