用 python 的 kafka 给后台传数据,明明没有任何异常,数据也正常传输了,但是消费者一直在等待,没有数据,后台也没看到数据,是我哪里设置出错了么?


1
zhuyang 2021-11-05 10:20:22 +08:00
# block until all async messages are sent
producer.flush() 或者 f = producer.send() 后 调用 f.get() |
2
zhuyang 2021-11-05 10:20:49 +08:00
|