ты не понял основной концепции. Например
1. сервис А читает поток инфы
2. что-то с ней делает
3. шлет сервису Б
вопрос:
организовать доставку этих данных, подтверждение и обработку, с учетом что это желательно делать потоком и желательно организовать отказоустойчивость
Общение через очередь и гарантии и отказоустойчивость, какую именно очередь теснить нужно