Afkak: Twisted Python Kafka Client

Afkak is a Twisted-native Apache Kafka client library. It provides support for:

  • Producing messages, with automatic batching and optional compression.
  • Consuming messages, with automatic commit.

Afkak 19.10.0 was tested against:

Python:CPython 2.7, 3.5+; PyPy, PyPy3 6.0+
Twisted:18.9.0
Kafka:0.9.0.1, 1.1.1

Newer broker releases will generally function, but not all Afkak features will work on older brokers. In particular, the coordinated consumer won’t work before Kafka 0.9.0.1. We don’t recommend deploying such old releases anyway, as they have serious bugs.

Indices and tables