RED Bus allows you to publish messages and process them with control over the result. You can set a retry strategy for each consumer and the number of retries after which a message will be marked as failed. The administrator can start reprocessing of unsuccessfully processed messages after fixing the problem through the web interface.
When you use messages in your system to maintain eventual consistency, it's important that every message is processed, and you must handle errors and implement a retry algorithm in every service in your system. You also need a tool to view failed messages and the ability to reprocess on demand.
Produce messages from anywhere and process them with repeated retries.
RED Bus will do the rest for you.
make build-
Start essential environment
docker-compose -f example/docker-compose.yml up
-
Run data bus service
./bin/databus
-
Try consumer and producer
- GoLang client
- Scala client (isn't working yet)