PyRank

Kafka Python Packages

Python packages with the GitHub topic kafka. Sorted by relevance, with stars and monthly downloads.
dpkp
kafka-python

Python client for Apache Kafka

23.5M 6K 1K
aio-libs
aiokafka

asyncio client for kafka

10M 1K 261
pirate
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...

3.6M 6 1
benbenbang
types-confluent-kafka

Typings for Confluent Kafka Python Client

1.8M 27 18
wbarnha
kafka-python-ng

Fork for Python client for Apache Kafka

1.5M 105 13
ag2ai
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.

1M 5K 348
faust-streaming
faust-streaming

Python Stream Processing. A Faust fork

485K 2K 203
dpkp
kafka

Python client for Apache Kafka

384K 6K 1K
Parsely
pykafka

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

228K 1K 223
DisasterAWARE
aws-glue-schema-registry

Use the AWS Glue Schema Registry in Python projects.

123K 33 17
quixio
quixstreams

Python Streaming DataFrames for Kafka

87K 2K 106
getsentry
sentry-arroyo

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

76K 59 5
ArchiveBox
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...

72K 6 1
DhiaTN
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

61K 22 0
jpmorganchase
py-avro-schema

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

51K 45 12
alm0ra
mockafka-py

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

41K 64 17
ApiLogicServer
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.

24K 50 11
robinhood
faust

Python Stream Processing

20K 7K 536
RegioHelden
django-kafka

Confluent's Kafka Python Client combined with Django

17K 14 4
taskiq-python
taskiq-faststream

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

14K 57 10
dpkp
kafka-python3

Python client for Apache Kafka

13K 6K 1K
pathwaycom
pathway

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

12K 63K 2K
ryan-evans-git
ematix-flow

Move data between databases, files, and streams from Python. 5.87× faster than PySpark.

10K 0 0
aleksul
repid

Repid is a simple, fast, and extensible async task queue framework, with built-in AsyncAPI 3.0 schema generation

9K 109 6