aio-libs/aiokafka

Health v2 · maintenance only

Adoption not part of the score

1399 stars · 266 forks observed · 2026-08-28

What it is AI-extracted, prompt v1, taxonomy v1, 2026-08-30, confidence not recorded

aiokafka is an asyncio-based Python client library for Apache Kafka, providing AIOKafkaProducer and AIOKafkaConsumer high-level classes. It enables asynchronous producing and consuming of Kafka messages with consumer group support.

Use cases

• produce messages to kafka from async python code
• consume kafka topics asynchronously
• build event-driven services with asyncio and kafka
• load balance kafka consumption across consumer groups
• integrate kafka into fastapi or aiohttp apps
• stream processing pipelines in python

When to choose

• your application uses asyncio and needs kafka integration
• you want a pure-python async kafka client without blocking the event loop
• you need consumer group rebalancing in async code

When to avoid

• your codebase is synchronous and you don't use asyncio
• you need features of a full streaming platform rather than a client library
• you need a kafka client for another language

Facets

library · maturity active

message-queue database-driver streaming microservices backend python cross-platform asyncio kafka kafka-client producer consumer messaging data-engineering

Member repositories

For agents

markdown · JSON · MCP: product_card(name="aio-libs/aiokafka")