Apache Kafka Python Packages

pykafka

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

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

littlehorse-client

LittleHorse Server: the command center for Microservices & Business-as-Code

fink-client

Light-weight client to manipulate alerts from Fink

streams-explorer

Explore Apache Kafka data pipelines in Kubernetes.

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

esque

esque - an operational kafka tool.

quantum-pipeline

Framework for running, monitoring and analysing quantum algorithms.

pyrkafka

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

typedkafka

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

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

kafka-overwatch

Tool for Kafka Monitoring, Reporting, and Tuning

websites-metrics-consumer

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

kafka-handler

A simple Kafka wrapper based on confluent_kafka python client.

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

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

websites-metrics-collector

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

kafka-replay

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