exactly-once
Lightweight Python message queuing with Redis and built-in publish-side deduplication.
Exactly-once + circuit breaker for agent tool calls (loops, retries, duplicate side effects)
Kafka Streams API implementation for Python - built upon synchronous producer and consumer