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 21.5.0 was tested against:

Python:CPython 3.5+; PyPy3
Twisted:21.2.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