Description
A service that listens for response messages coming from go sender, collects delivery (sent) reports and sends them when they are ready. The term ready is defined by the time that passed since messages had been started to be organized into groups in order to aggregate them before sending back to the main production cluster.
At the same time, the service is also looking for errors within those responses and sends them immediately back to the amazon cluster so they can be handled there by appropriate services.
Data flow
Input
Takes data from the sender-messages-responses key that is being stored there as a LIST.
Output
All data is being sent to the master cluster via Kafka which is being consumed by the sender-events-proxy
Here is the list of events that are being sent:
Links
-
dependencies: