Kafka Python Packages

kafka-python

Python client for Apache Kafka

aiokafka

asyncio client for kafka

bubus

📢 Fast in-memory Python & Typescript event bus library with support for advanced concurrency control features, nested event tracking, Pydantic & Zod type enforcement, and more...

types-confluent-kafka

Typings for Confluent Kafka Python Client

kafka-python-ng

Fork for Python client for Apache Kafka

faststream

FastStream is a powerful and easy-to-use asynchronous Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS, MQTT and Redis.

faust-streaming

Python Stream Processing. A Faust fork

kafka

Python client for Apache Kafka

pykafka

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

aws-glue-schema-registry

Use the AWS Glue Schema Registry in Python projects.

quixstreams

Python Streaming DataFrames for Kafka

sentry-arroyo

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

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

py-avro-schema

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

mockafka-py

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

abxbus

📢 Fast in-memory Python & Typescript event bus library with support for advanced concurrency control features, nested event tracking, Pydantic & Zod type enforcement, and more...

faust

Python Stream Processing

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.

taskiq-faststream

FastStream - Taskiq integration to provide you with a great scheduling feature

pathway

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

django-kafka

Confluent's Kafka Python Client combined with Django

kafka-python3

Python client for Apache Kafka

integration-automation-patterns

Enterprise integration patterns: idempotent event processing, saga orchestration, transactional outbox, and webhook validation for reliable system-of-record sync

funboost

pip install funboost，python全功能分布式函数调度框架,funboost的功能是全面性重量级，用户能想得到的功能99%全都有;funboost的使用方式是轻量级，只有@boost一行代码需要写。支持python所有类型的并发模式和一切知名消息队列中间件，支持如 celery dramatiq等框架整体作为funboost中间件，python函数加速器，框架包罗万象，用户能想到的控制功能全都有。一统编程思维，兼容50% python业务场景，适用范围广。只需要一行代码即可分布式执行python一切函数，99%用过funboost的pythoner 感受是　简易 方便 自由 强大，相见恨晚 。