Mockafka-py is a Python library designed for in-memory mocking of Kafka.[aiokafka - confluence-kafka-python]
-
Updated
Nov 11, 2024 - Python
Mockafka-py is a Python library designed for in-memory mocking of Kafka.[aiokafka - confluence-kafka-python]
Kafka PoC using FastAPI
Example of working with kafka clients in python
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.
Add a description, image, and links to the aiokafka topic page so that developers can more easily learn about it.
To associate your repository with the aiokafka topic, visit your repo's landing page and select "manage topics."