在我的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