aiokafka is the asyncio Kafka client for Python, maintained by the aio-libs community. It implements the Kafka protocol in Python, with Cython extensions for encoding and decoding records, instead of wrapping librdkafka. Versions 0.13.0 and 0.14.0 shipped in January and April 2026, 0.15.0rc1 followed on 17 October 2026. pypistats.org counted about 13 million downloads in the 30 days to 23 October 2026. If you run an asyncio service on it, five things deserve a check: when offsets are committed, what a blocking call does to the consumer group, when a sent record is actually delivered, how durable the producer defaults are, and how the group rebalances.

TL;DR: aiokafka gives asyncio services a producer and a consumer with async start and stop, transactions, idempotent production, and the same key-to-partition mapping as the Java client. By default, it commits offsets every 5 seconds, including records your code has not finished, so a crash can skip a record.…