【kafka】celery與kafka的聯用問題

背景：一個小應用，用celery下發任務，任務內容爲kafka生產一些數據。json 問題：使用confluent_kafka模塊時，單獨啓用kafka能夠正常生產消息，可是套上celery後，kafka就沒法將新消息生產到topic隊列中了。app 解決：換了個pykafka模塊，結果問題就沒有了。post   我很疑惑啊，是我調用confluent_kafka的方法不對嗎，怎麼套上celery

>>阅读原文<<