19 results for “topic:aiokafka”
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.
Order Service is a microservice responsible for managing orders in the Microshop project.
No description provided.
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
The Message Generator API is a versatile tool designed to generate and push messages to various message queues through a unified API interface.
Async order system using FastAPI, Redis, Kafka with resilient flow
Хакатон ЕВРАЗа 2.0
No description provided.
No description provided.
🕸️ Distributed Web Scraper with FastAPI, Kafka, Redis & Celery
High-performance, async Kafka library for Python. Use simple decorators (@consumer, @producer) to define your message handlers without dealing with AIOKafka boilerplate code. Built on asyncio for maximum throughput.
FastAPI/SQLAlchemy/Kafka Проект по обработке заявок
Simple example of dockerized Market on Python. Need some work&fixes