pykafka 生产者无法传输数据？

[perpetually]

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

[zhuyang]

# block until all async messages are sent
producer.flush()

或者 f = producer.send() 后 调用 f.get()

[zhuyang]

https://kafka-python.readthedocs.io/en/master/usage.html

[perpetually]

@zhuyang kafka.errors.KafkaTimeoutError: KafkaTimeoutError: Timeout after waiting for 3 secs.
使用 f.get()就会出现这个错误