如何解决kafka模块SyntaxError及kafka-python导入KafkaConsumer报错问题

原因 #

当前Python环境中安装的是名为kafka的第三方旧包，并非你需要的kafka-python官方客户端，该包没有封装KafkaConsumer相关实现，导致导包失败。

解决方案 #

• 先卸载冲突的错误包：

pip uninstall kafka -y

• 卸载残留的kafka-python包避免安装冲突：

pip uninstall kafka-python -y

• 重新安装稳定版kafka-python：

pip install kafka-python==2.0.2

• 验证是否修复：执行python -c "from kafka import KafkaConsumer; print('导入成功')"，无报错即为解决。

原因 #

async是Python3.7及以上版本的保留关键字，你此前安装的旧版kafka包是适配Python2的版本，代码中直接使用async作为属性名，在Python3环境下会直接触发语法错误，你推测的版本过旧是正确的，本质是安装了错误的依赖包。

解决方案 #

执行上述报错1的卸载重装步骤即可，安装正确的kafka-python包后该语法错误会直接消失。

• 如果你使用虚拟环境，操作前需要先激活对应的虚拟环境，避免卸载、安装操作作用到全局Python环境导致不生效
• 不要同时安装kafka和kafka-python两个依赖，两者的导入命名空间都是kafka，会互相覆盖触发异常

内容的提问来源于stack exchange，提问作者Vijay Kumar