kafkapython客户机如何计算对象到达给定kafka主题的等待时间

vof42yt1  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(154)

kafkapython客户机如何计算对象到达给定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))

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题