python3.7新增關(guān)鍵字:async茉帅、await粹懒;
kafka-python 用到了關(guān)鍵字async嘱吗,由此帶來兼容性問題
解決方案:
異步用aiokafka增热,同步就是python-kakfa
1整以、升級kafka-python==1.4.6
pip install kafka-python
kafka-python官網(wǎng)文檔支持的Python版本是3.7.1,親測3.7.2 和3.7.3都不行峻仇!
到目前時間為止3.7.1能兼容kafka-python
2公黑、使用python3.7.1或以下版本