I am new at Kafka. I want to consume messages which are compresses by snappy. I see that aiokafka automatically decompress messages. So that, snappy package should be installed.
When I try to install python-snappy package as how it is said herepip install 'aiokafka[snappy]'
or
via pip install python-snappy, I got error
Building wheel for python-snappy (setup.py) ... error
ERROR: Command errored out with exit status 1:
...
src/snappy/snappymodule.cc:33:10: fatal error: 'snappy-c.h' file not found
It is due to this package doesn't have wheels for Python 3.11. An issue exists at the project regarding this.
I think I can apply those solutions to solve the issue:
Build and install package manually: I don't want to do this
Wait wheels publish for 3.11 from the package: I don't know when it will be available
Get compressed raw message without any decompression by aiokafka and decompress it manually by using other packages like that: It is what I prefer.
Hello,
I am new at Kafka. I want to consume messages which are compresses by snappy. I see that aiokafka automatically decompress messages. So that, snappy package should be installed.
When I try to install
python-snappy
package as how it is said herepip install 'aiokafka[snappy]'
or viapip install python-snappy
, I got errorIt is due to this package doesn't have wheels for Python 3.11. An issue exists at the project regarding this.
I think I can apply those solutions to solve the issue:
Is the third one possible right now?
I am looking for your helps and ideas.
Thank you