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))
暂无答案!
目前还没有任何答案,快来回答吧!