Simple Message forwarder between Kafka clusters.
Cluster and forwarding configuration is written in a simple DSL (see main_example.py).
This is free software an there are no guarantees at all.
Yet, in principle this service should provide at least once delivery, but not exactly once. E.g. aborting the program while sending a message will resend the message and several before, regardless of whether they were already successfully delivered.
Multiple instances will share the workload (via Kafka's usual group_ids).