python3.7新增关键字:async、await;
kafka-python 用到了关键字async,由此带来兼容性问题
解决方案:
异步用aiokafka,同步就是python-kakfa
1、升级kafka-python==1.4.6
pip install kafka-python
kafka-python官网文档支持的Python版本是3.7.1,亲测3.7.2 和3.7.3都不行!
到目前时间为止3.7.1能兼容kafka-python
2、使用python3.7.1或以下版本
网友评论