Install with your favorite package manager
Latest ReleasePip:
Releases are also listed at https://github.com/dpkp/kafka-python/releases
Bleeding-Edgegit clone https://github.com/dpkp/kafka-python pip install ./kafka-pythonOptional crc32c install
Highly recommended if you are using Kafka 11+ brokers. For those kafka-python uses a new message protocol version, that requires calculation of crc32c, which differs from the zlib.crc32 hash implementation. By default kafka-python calculates it in pure python, which is quite slow. To speed it up we optionally support https://pypi.python.org/pypi/crc32c package if it’s installed.
pip install 'kafka-python[crc32c]'Optional ZSTD install
To enable ZSTD compression/decompression, install python-zstandard:
>>> pip install 'kafka-python[zstd]'Optional LZ4 install
To enable LZ4 compression/decompression, install python-lz4:
>>> pip install 'kafka-python[lz4]'Optional Snappy install Install Development Libraries
Download and build Snappy from https://google.github.io/snappy/
Ubuntu:
apt-get install libsnappy-dev
OSX:
From Source:
wget https://github.com/google/snappy/releases/download/1.1.3/snappy-1.1.3.tar.gz tar xzvf snappy-1.1.3.tar.gz cd snappy-1.1.3 ./configure make sudo make installInstall Python Module
Install the python-snappy module
pip install 'kafka-python[snappy]'
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4