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

Kafka PoC using FastAPI

Kafka streams processing in Python.

A FastAPI-inspired framework to build production-grade Kafka applications effortlessly, with support for routing, DI, retries, DLQ, and custom serialization.

Concurrent message-processing middleware for FastStream + aiokafka

Order Service is a microservice responsible for managing orders in the Microshop project.

Payment Service is a microservice for handling payments, managing invoices and transactions, and integrating with multiple external payment providers in the Microshop project.

Group consumer using AIO Python Kafka client on a Tansu topic backed by S3

This demo solution uses Kafka, Clickhouse and presents two services written on Python3: price-generator and price-monitor. The first one generates an array of 52 items of random trade data every millisecond and writes it to Kafka. The second consumes hot data from Kafka and with minimal latency sends a notification when a trade condition occurs.

Example of working with kafka clients in python

Real-time anomaly detection pipeline — Kafka → FastAPI → Isolation Forest + Autoencoder → WebSocket dashboard. Sub-500ms end-to-end latency.

Async Kafka consumer base for Python — at-least-once delivery, dead-letter queue, batch processing, Prometheus metrics

Хакатон ЕВРАЗа 2.0

🕸️ Distributed Web Scraper with FastAPI, Kafka, Redis & Celery

The Message Generator API is a versatile tool designed to generate and push messages to various message queues through a unified API interface.

A complete data fabric for an integrated security command and control system.

Async order system using FastAPI, Redis, Kafka with resilient flow