kafka-python客户端如何计算对象到达给定kafka主题的等待时间的秒数

问题描述

kafka-python客户端如何计算对象到达给定kafka主题的等待时间的秒数。 可以说客户已经订阅了kafka主题，并且正在等待消息到达，因为我们不知道生产者何时将消息推送到其中。如何找出轮候时间？我有如下代码：我没有使用使用者组。在单个线程中使用一个单个kafka-python客户端。

from kafka import KafkaConsumer
consumer=KafkaConsumer(bootstrap_servers=some_host:9092,auto_offset_reset='earliest')
consumer().subscribe([some_topic])
for message in consumer:# do need to kNow the waiting time 
    item=dict(loads(message.value))

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）