Kafka Python Packages

kafka-python

Python client for Apache Kafka

27M 6K 1K

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...

14.6M 12 2

aiokafka

asyncio client for kafka

10.8M 1K 262

svix

The open source and enterprise-ready webhooks service 🦀

7.5M 3K 259

kafka-python-ng

Fork for Python client for Apache Kafka

1.5M 105 13

faststream

FastStream is an asynchronous Python framework for building event-driven applications. It brings together message broker integration, dependency injection, validation, testing utilities, and AsyncAPI documentation generation in a single toolkit

1.2M 5K 360

types-confluent-kafka

Typings for Confluent Kafka Python Client

1.2M 27 18

abxbus

379K 12 2

kafka

Python client for Apache Kafka

313K 6K 1K

faust-streaming

Python Stream Processing. A Faust fork

310K 2K 204

pykafka

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

151K 1K 222

aws-glue-schema-registry

Use the AWS Glue Schema Registry in Python projects.

109K 33 17

py-avro-schema

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

102K 46 13

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

78K 22 0

quixstreams

Python Streaming DataFrames for Kafka

77K 2K 107

sentry-arroyo

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

50K 62 5

mockafka-py

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

43K 64 17

pathway

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

32K 63K 2K

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.

22K 51 11