pythonapache-kafkacompressionconfluent-kafka-python

0x4 Decompression error in Python Confluent Kafka


I've been having trouble getting python-confluent-kafka to work on my windows server.

When creating a simple consumer on my local machine, everything works fine. However, once on the windows server, I will receive the messages but get the following error:

b'Decompression (codec 0x4) of message at 24023756 of 9550 bytes failed: Local: Not implemented'

I copied the exact conda environment I have on my local machine to the server.


Solution

  • Turns out it had to do with the .dll's not being found due to the Path/Environment Variables not being configured properly.