python - ImportError:无法导入名称“kafkaProducer”
问题描述
我正在使用 CentOS 并已安装 Python 3。已使用以下命令安装了 Kakfa-Python。
sudo python3 -m pip install kafka-python
然后我启动 Python shell 并尝试导入 kafkaProducer。但我得到了错误。
$ python3
Python 3.6.8 (default, Aug 7 2019, 17:28:10)
[GCC 4.8.5 20150623 (Red Hat 4.8.5-39)] on linux
Type "help", "copyright", "credits" or "license" for more information.
>>> from kafka import kafkaProducer
Traceback (most recent call last):
File "<stdin>", line 1, in <module>
ImportError: cannot import name 'kafkaProducer'
然后我尝试了下面的代码以确保模块没有被导入。
>>> producer = kafkaProducer(bootstrap_servers='host1')
Traceback (most recent call last):
File "<stdin>", line 1, in <module>
NameError: name 'kafkaProducer' is not defined
大多数情况下,“无法导入名称xxxxxx”错误是由模块名称冲突引起的,我可以通过重命名自己的python脚本文件来修复它。但是,现在我在 REPL 中,还没有创建任何文件/模块。
解决方案
它KafkaProducer
不是kafkaProducer
推荐阅读
- node.js - Typescript decorators still experimental?
- javascript - HighChart中的甘特图?
- r - Write output of R loop to output file or indicate progress?
- android - Certain physical device shows different background color than selected and showed by other devices
- python - Expand a dictionary column into rows with both dict keys and dict values as new column values in pandas
- entity-framework-6 - Error- Unable to determine the provider name for provider factory of type 'Npgsql.NpgsqlFactory' in .net core 5 with npgsql
- javascript - How to dynamically change icon name?
- scrapy - Scrapy css selector not getting text in
- ios - didReceiveNewSession method of QBRTCClientDelegate is not getting invoked
- javascript - 无法读取未定义 Get @input 的属性“charAt”