用 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
|
3
perpetually OP @zhuyang kafka.errors.KafkaTimeoutError: KafkaTimeoutError: Timeout after waiting for 3 secs.
使用 f.get()就会出现这个错误 |