我有 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
关于python - 获取我的 Kafka 队列中的最新消息时间戳，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/53852335/