求助:导入KafkaConsumer/Producer时出现IncompatibleBrokerVersion导入错误
解决ImportError: cannot import name 'IncompatibleBrokerVersion' from 'kafka.errors'问题
你遇到的问题核心原因是当前目录下存在同名的kafka.py文件,导致Python优先加载本地文件而非你安装的kafka-python官方包,进而引发导入异常。按以下步骤处理:
- 找到当前工作目录中的
kafka.py文件,将其重命名为其他名称(比如local_kafka_helper.py),彻底避免包名冲突。 - 删除目录下自动生成的
kafka.pyc文件和__pycache__文件夹(如果存在),这些缓存文件可能依然会干扰模块导入。 - 重新运行导入代码,验证问题是否解决。
如果问题依旧,检查kafka-python版本:部分旧版本的kafka-python中没有IncompatibleBrokerVersion这个异常类,执行以下命令升级到最新稳定版:
pip install --upgrade kafka-python
内容的提问来源于stack exchange,提问作者user2540646
相关产品推荐
相关产品推荐

