kafka-python.readthedocs.io - kafka-python — kafka-python 2.0.2-dev documentation

Example domain paragraphs

Python client for the Apache Kafka distributed stream processing system. kafka-python is designed to function much like the official java client, with a sprinkling of pythonic interfaces (e.g., consumer iterators).

kafka-python is best used with newer brokers (0.9+), but is backwards-compatible with older versions (to 0.8.0). Some features will only be enabled on newer brokers. For example, fully coordinated consumer groups – i.e., dynamic partition assignment to multiple consumers in the same group – requires use of 0.9 kafka brokers. Supporting this feature for earlier broker releases would require writing and maintaining custom leadership election and membership / health check code (perhaps using zookeeper or consu

Please note that the master branch may contain unreleased features. For release documentation, please see readthedocs and/or python’s inline help.

Links to kafka-python.readthedocs.io (4)