exactly-once-processing
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.
Lightweight Python message queuing with Redis and built-in publish-side deduplication.