当前位置:   article > 正文

【代码实践】运行kafka出现ModuleNotFoundError: No module named ‘kafka.vendor.six.moves‘_modulenotfounderror: no module named 'kafka.vendor

modulenotfounderror: no module named 'kafka.vendor.six.moves

python版本:3.12.4

最近更新了一下python版本,升级到3.12.4版本,发现原来和kafka交互的代码突然报错了。

  1. python
  2. Python 3.12.4 (v3.12.4:8e8a4baf65, Jun 6 2024, 17:33:18) [Clang 13.0.0 (clang-1300.0.29.30)] on darwin
  3. Type "help", "copyright", "credits" or "license" for more information.
  4. >>> from kafka.consumer.group import KafkaConsumer
  5. Traceback (most recent call last):
  6. File "<stdin>", line 1, in <module>
  7. File "/Library/Frameworks/Python.framework/Versions/3.12/lib/python3.12/site-packages/kafka/__init__.py", line 23, in <module>
  8. from kafka.consumer import KafkaConsumer
  9. File "/Library/Frameworks/Python.framework/Versions/3.12/lib/python3.12/site-packages/kafka/consumer/__init__.py", line 3, in <module>
  10. from kafka.consumer.group import KafkaConsumer
  11. File "/Library/Frameworks/Python.framework/Versions/3.12/lib/python3.12/site-packages/kafka/consumer/group.py", line 13, in <module>
  12. from kafka.consumer.fetcher import Fetcher
  13. File "/Library/Frameworks/Python.framework/Versions/3.12/lib/python3.12/site-packages/kafka/consumer/fetcher.py", line 19, in <module>
  14. from kafka.record import MemoryRecords
  15. File "/Library/Frameworks/Python.framework/Versions/3.12/lib/python3.12/site-packages/kafka/record/__init__.py", line 1, in <module>
  16. from kafka.record.memory_records import MemoryRecords, MemoryRecordsBuilder
  17. File "/Library/Frameworks/Python.framework/Versions/3.12/lib/python3.12/site-packages/kafka/record/memory_records.py", line 27, in <module>
  18. from kafka.record.legacy_records import LegacyRecordBatch, LegacyRecordBatchBuilder
  19. File "/Library/Frameworks/Python.framework/Versions/3.12/lib/python3.12/site-packages/kafka/record/legacy_records.py", line 50, in <module>
  20. from kafka.codec import (
  21. File "/Library/Frameworks/Python.framework/Versions/3.12/lib/python3.12/site-packages/kafka/codec.py", line 9, in <module>
  22. from kafka.vendor.six.moves import range
  23. ModuleNotFoundError: No module named 'kafka.vendor.six.moves'

解决办法:卸载原理的kafka-python包,已经不兼容最新的python版本,安装kafka-python-ng包。

  1. pip3 install kafka-python
  2. pip3 install kafka-python-ng

验证OK:

  1. python
  2. Python 3.12.4 (v3.12.4:8e8a4baf65, Jun 6 2024, 17:33:18) [Clang 13.0.0 (clang-1300.0.29.30)] on darwin
  3. Type "help", "copyright", "credits" or "license" for more information.
  4. >>> from kafka.consumer.group import KafkaConsumer
  5. >>>
  6. >>> quit()

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/空白诗007/article/detail/966569
推荐阅读
相关标签
  

闽ICP备14008679号