在我的 Kafka 队列中获取最新的消息时间戳
Getting latest message timestamp in my Kafka queue
我有 Kafka 0.10.0，如果我理解正确的话，它会为所有消息添加时间戳。出于监控目的，我想提取给定主题的最新消息的时间戳。在我查看过的任何 Python 库中，我都没有看到它的 API 字段。
没有直接的方法可以从 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
我有 Kafka 0.10.0，如果我理解正确的话，它会为所有消息添加时间戳。出于监控目的，我想提取给定主题的最新消息的时间戳。在我查看过的任何 Python 库中，我都没有看到它的 API 字段。
没有直接的方法可以从 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