Пример агрегатора потока данных Spring Cloud

Может ли кто-нибудь указать на некоторые примеры, относящиеся к потоку данных String Cloud (не Stream XD), о том, как писать разбиители и агрегаторы?

В частности, нетривиальное разбиение и объединение сообщений. Любой нетривиальный пример сложных потоков. Как вы определяете поток, который агрегирует сообщения после разбиения, как насчет того, когда есть маршрутизаторы и различная обработка для произведенных сообщений, как все это агрегируется позже?

PS: извините за длинный вопрос, я уточню по мере необходимости.
Спасибо!

1 ответ