用 python 的 kafka 给后台传数据，明明没有任何异常，数据也正常传输了，但是消费者一直在等待，没有数据，后台也没看到数据，是我哪里设置出错了么？
This topic created in 1776 days ago, the information mentioned may be changed or developed.
Supplement 1 · Nov 5, 2021
解决了，是因为 c 盘 host 出问题了
 |
1
zhuyang Nov 5, 2021
# block until all async messages are sent
producer.flush() 或者 f = producer.send() 后 调用 f.get() |
 |
3
perpetually2016 OP @zhuyang kafka.errors.KafkaTimeoutError: KafkaTimeoutError: Timeout after waiting for 3 secs.
使用 f.get()就会出现这个错误 |
Select Language