Mockafka-py is a Python library designed for in-memory mocking of Kafka.[aiokafka - confluence-kafka-python]
-
Updated
Oct 26, 2026 - Python
GeezerVisonThe World Wide Web, restored to 800 pixels of glory. |
| Home|About|Gaming cabinet|Archives|How it works|Starter sites |
GeezerVison is showing github.com — Build software better, together
#
aiokafkaHere are 28 public repositories matching this topic...Language: All
Filter by language
Sort: Most stars
Sort options
Kafka PoC using FastAPI
docker dockerfile kafka docker-compose kafka-consumer kafka-producer zookeper kafkacat fastapi aiokafka
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.
docker sqlalchemy kafka docker-compose makefile rest-api postgresql python3 aiohttp minio asyncio alembic bs4 asyncpg aiobotocore kafka-ui fastapi aiokafka presigned-url
Python library for testing aiokafka apps
Group consumer using the asyncio Python Kafka client on a Nisshi 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
Async Kafka foundation kit built on aiokafka — lifecycle helpers, Pydantic settings, DI integrations
python streaming kafka async messaging foundation consumer producer observability opentelemetry aiokafka dishka
Real-time anomaly detection pipeline — Kafka → FastAPI → Isolation Forest + Autoencoder → WebSocket dashboard. Sub-500ms end-to-end latency.
react python kafka docker-compose websocket pytorch stream-processing autoencoder recharts apache-kafka anomaly-detection isolation-forest fastapi real-time-ml aiokafka
music kafka deep-learning tensorflow numpy scikit-learn keras pandas music-information-retrieval asyncio convolutional-neural-networks apache-kafka music-genre-classification genre-classification uvicorn fastapi aiokafka
Async Kafka consumer base for Python — at-least-once delivery, dead-letter queue, batch processing, Prometheus metrics
Real-time flight telemetry platform streaming simulated data via Kafka, FastAPI, Redis & WebSockets to a live dashboard. Dockerized, event-driven backend architecture.
python docker redis real-time microservices backend async docker-compose websockets telemetry plotly apache-kafka data-streaming event-driven-architecture fastapi aiokafka
Add this topic to your repoTo associate your repository with the aiokafka topic, visit your repo's landing page and select "manage topics." |
| You are visitor 01402503 — GeezerVison does not store the pages you look up. Best viewed with Netscape Navigator 4.7 or Internet Explorer 6 at 800×600. No cookies required. |