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

A medium for linking mqtt to kafka

Tool to manage kafka topics

A simple Kafka wrapper based on confluent_kafka python client.

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

Kafka-based Job Queue for Python

An example of how to integrate FastAPI with Kafka

Kafka client written in Twisted Python

kafka_job_interface_service

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 CLI tool to fetch Kafka messages within a specified time range

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.

asyncio client for kafka

Confluent's Kafka Python Client

Kafka S3 Connector kaf-s3: A Python library that offloads Kafka messages to S3, with a producer and consumer using lightweight references and IAM-based access 🐙