0
Может ли кто-нибудь указать на некоторые примеры, специфичные для потока данных потоков String (не Stream XD) о том, как записывать сплиттеры и агрегаторы?Пример агрегатора потока данных Spring Cloud
В частности, нетривиальное разделение и объединение сообщений. Любой нетривиальный пример сложных потоков. Как вы определяете поток, который агрегирует сообщения после сплитрования, как насчет того, когда есть маршрутизаторы и другая обработка для созданных сообщений, как все это агрегируется позже?
PS: Извините за длинный вопрос, я уточню при необходимости. спасибо!
Спасибо! Я прочитал предоставленные ссылки и еще кое-что, что может быть полезно, если кто-нибудь найдет этот вопрос: [link] https://github.com/spring-cloud/spring-cloud-stream-app-starters содержит другие стартеры. Генератор, который я получил на основе документации, очень прост, метод с аннотацией @Agregator, список параметров Message as и возврат одного результата сообщения ... Все еще не отвечает на проблему примеров сложных потоков. – ka2
Я буду отмечать это как ответ, поскольку он дает хорошие ссылки, но было бы неплохо опубликовать более сложные примеры ... – ka2