【kafka】celery与kafka的联用问题

背景：一个小应用，用celery下发任务，任务内容为kafka生产一些数据。json 问题：使用confluent_kafka模块时，单独启用kafka能够正常生产消息，可是套上celery后，kafka就没法将新消息生产到topic队列中了。app 解决：换了个pykafka模块，结果问题就没有了。post   我很疑惑啊，是我调用confluent_kafka的方法不对吗，怎么套上celery

>>阅读原文<<