asyncio client for kafka

Kafka-based Job Queue for Python

Confluent's Kafka Python Client

Manage your topic's configuration (partitions, replication factor, parameters), ACLs, quotas, users and get stats, without any effort with this library. It does not use the Kafka scripts and does not require ssh connection to the remote broker.

Kafka client written in Twisted Python

A Kafka python library for Robotframework to test events(messages) in Kafka.

Python library to handle large Kafka messages by offloading them to S3.

A simple Kafka wrapper based on confluent_kafka python client.

A medium for linking mqtt to kafka

An example of how to integrate FastAPI with Kafka

A single Python CLI to find duplicates, check consumer lag, grep topics, peek at messages, and more. Fast, efficient, and indispensable for Kafka debugging and inspection.

Real-time data streaming project using Python, Pandas, and Confluent Kafka to publish and consume retail data through Kafka topics, demonstrating scalability and dynamic consumer behavior.

A streaming event pipeline around Apache Kafka that allows us to simulate and display the status of train lines in real time

Python Restful service with elasticsearch and kafka integration

A CLI tool to fetch Kafka messages within a specified time range

kafka_job_interface_service

Tool to manage kafka topics