Mockafka-py is a Python library designed for in-memory mocking of Kafka.[aiokafka - confluence-kafka-python]
-
Updated
Dec 12, 2024 - Python
Mockafka-py is a Python library designed for in-memory mocking of Kafka.[aiokafka - confluence-kafka-python]
Kafka PoC using FastAPI
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
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."