# aio-libs/aiokafka

asyncio client for kafka

Repository: https://github.com/aio-libs/aiokafka
Canonical: https://ross.abutalabs.com/products/aiokafka
Homepage: http://aiokafka.readthedocs.io/
Language: Python
License: Apache-2.0
License Family: permissive
Topics: asyncio, kafka, kafka-client
Last push: 2026-08-09T13:30:45+00:00

## Health v2 (maintenance only)
Score: 80/100 (v2, computed 2026-09-02T17:46:02.011165+00:00)
- activity 96, release rhythm 49, longevity 100
- inputs: {"age_days": 4323, "days_push": 24, "days_rel": 126, "gap_med": 274.0, "n_releases_24m": 3}
- flags: none
- formula: round(0.45*activity + 0.35*rhythm + 0.20*longevity); archived -> min(score, 10)

## Adoption (not part of the score)
Stars 1399, forks 266 (observed 2026-08-28T04:04:37.046696+00:00)

## What it is
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
- artifact type: library
- maturity: active
- function: message-queue, database-driver, streaming
- domain: microservices, backend
- platform: python, cross-platform
- tags: asyncio, kafka, kafka-client, producer, consumer, messaging, data-engineering

## Member repositories
- aio-libs/aiokafka (main) score 80

## Provenance
- Observed fields: from GitHub, fetched 2026-08-28T04:04:37.046696+00:00.
- Health v2: computed from the inputs above; adoption is never an input.
- Inferred fields (summary, facets, guidance): AI-extracted, prompt v1, taxonomy v1, on 2026-08-30T04:39:09.660461+00:00, confidence not recorded.
  - readme: https://github.com/aio-libs/aiokafka (fetched 2026-08-28T04:04:37.046696+00:00, sha cfdb1eb69f6d)
  - registry_pypi: https://pypi.org/pypi/aiokafka/json (fetched 2026-08-29T11:53:55.452332+00:00, sha 0ef784a6bc90)
- Data as of 2026-08-30T08:39:29.467469+00:00.