Kafka Python Packages

kafka-python

Python client for Apache Kafka

aiokafka

asyncio client for kafka

svix

The open source and enterprise-ready webhooks service 🦀

bubus

📢 Fast multi-language Event Bus library for Python/TS/Golang/Rust with support for advanced concurrency control features, nested event tracking, type enforcement, bridges to other backends, and more...

faststream

Asynchronous Python framework for event-driven services. A thin client for Kafka, RabbitMQ, NATS, Redis and MQTT with full access to native broker features, plus AsyncAPI docs, in-memory tests and observability out of the box.

kafka-python-ng

Fork for Python client for Apache Kafka

types-confluent-kafka

Typings for Confluent Kafka Python Client

faust-streaming

Python Stream Processing. A Faust fork

kafka

Python client for Apache Kafka

abxbus

📢 Fast multi-language Event Bus library for Python/TS/Golang/Rust with support for advanced concurrency control features, nested event tracking, type enforcement, bridges to other backends, and more...

quixstreams

Python Streaming DataFrames for Kafka

sentry-arroyo

A library to build streaming applications that consume from and produce to Kafka.

aws-glue-schema-registry

Use the AWS Glue Schema Registry in Python projects.

py-avro-schema

Generate Apache Avro schemas for Python types including standard library data-classes and Pydantic data models.

scalo

Opinionated-for-scale integrated runtime of config, logging, secrets, cli and more for control-plane services.

mockafka-py

Mockafka-py is a Python library designed for in-memory mocking of Kafka.[aiokafka - confluence-kafka-python]

confluent-avro

An Avro SerDe implementation that integrates with the confluent schema registry and serializes and deserializes data according to the defined confluent wire format

kafka-viewer

A lightweight local UI for inspecting Kafka messages.

pathway

Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.

gcn-kafka

Official Python client for the General Coordinates Network (GCN)

beavers

Python stream processing for analytics

pykafka

Apache Kafka client for Python; high-level & low-level consumer/producer, with great performance.

apilogicserver

Create an executable project (API and Admin App) from a database or natural language prompt with 1 command, customize with declarative rules and Python in your IDE, containerize and deploy.

atengk-mcp-server-kafka

基于 Python 与 FastMCP 构建的生产级 Apache Kafka 模型上下文协议 (MCP) 服务端，具备双重安全防线、零位移侵入消息采样与 Stdio/SSE 双模网关