找不到 lz4 压缩编解码器的库 - kafka python

Question

使用 kafka python 时出错（kafka-python 1.4.7）

Kafka消费者抛出错误

kafka.errors.UnsupportedCodecError：UnsupportedCodecError：找不到 lz4 压缩编解码器的库

Answer 1

在阅读文档时找到了解决方案

https://kafka-python.readthedocs.io/en/master/install.html

刚刚使用 pip 安装了 lz4 并重新启动了它。

pip 安装 lz4

Answer 2

我也遇到了同样的问题 我是这样解决的

pip install 'aiokafka[lz4]'

你可以在这里找到它

https://aiokafka.readthedocs.io/en/stable/