PyPI page
Home page
Author:
Christian Schlichtherle, Viktor Penev
License:
MIT
Summary:
Truly async Python stream processing with real Kafka transactions for exactly-once delivery, and an MQTT→Kafka bridge that ACKs only after Kafka has the data.
Latest version:
0.17.0
Required dependencies:
aiokafka
|
prometheus-client
|
reactor-di
|
rocksdict
Optional dependencies:
flechtctl
|
paho-mqtt
Downloads last day:
64
Downloads last week:
610
Downloads last month:
580
7-day smoothing