Apache Kafka Python Packages

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

pykafka

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

atengk-mcp-server-kafka

基于 Python 与 FastMCP 构建的生产级 Apache Kafka 模型上下文协议 (MCP) 服务端，具备双重安全防线、零位移侵入消息采样与 Stdio/SSE 双模网关

odctl

A curated collection of open source technologies and the odctl CLI for running a local Docker-based data platform to experiment with modern data architecture and MLOps.

fink-client

Light-weight client to manipulate alerts from Fink

littlehorse-client

LittleHorse Server: Business-as-Code Platform for Microservices, Workflows, and Agents

streams-explorer

Explore Apache Kafka data pipelines in Kubernetes.

quantum-pipeline

A Python module for executing and monitoring quantum algorithms across local simulators and IBM Quantum platforms. Seamlessly handles data collection, organization, and streaming to Apache Kafka.

esque

esque - an operational kafka tool.

kq

Kafka-based Job Queue for Python

khaos-cli

Kafka data generator and load testing tool - generate fake messages, simulate producers and consumers, test broker failures, and run chaos engineering scenarios

pyrkafka

Fast Python Kafka client powered by Rust and librdkafka — producer and consumer with native performance

chatpulse-cli

Distributed real-time chat backend built with Django REST, Kafka, Redis, PostgreSQL, JWT, and a Python CLI.

iflow-mcp-aywengo-kafka-schema-registry-mcp

A comprehensive Message Control Protocol (MCP) server for Kafka Schema Registry.

kafka-overwatch

Tool for Kafka Monitoring, Reporting, and Tuning

samsa

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

pyspark-streaming-base

This project provides an opinionated way to go about crafting Spark Structured Streaming applications with PySpark

typedkafka

A well-documented, fully type-hinted Kafka client for Python

kafka-handler

A simple Kafka wrapper based on confluent_kafka python client.

websites-metrics-consumer

A small distributed application that aims to produce and collect metrics about the availability of one or more websites.

kafka-replay

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

websites-metrics-collector

A small distributed application that periodically produces and collects metrics about the availability of one or more websites