Мне нужен способ динамического разрешения входящего канала в зависимости от типа входящего сообщения. Я не ищу какое-либо решение на основе заголовков, которое уже упоминалось в этой ссылке...

Я изо всех сил пытаюсь понять, как мне следует тестировать приложение, которое использует Kafka Binder, а также использует функцию Spring Cloud. Давайте воспользуемся этим очень простым примером: @SpringBootApplication public class...

У меня есть компонент потока Spring Integration (настроенный через Java DSL), который обрабатывает сообщения из канала сообщений очереди kafka, связанного с Spring CloudStream. Источником сообщения kafka является внешнее приложение, поэтому я...

У меня есть тема и связанный с ней DLQ. Я использую @StreamListener для этой темы. Я хотел читать / обрабатывать сообщения из DLQ по запросу с помощью конечной точки контроллера. можно ли это сделать с помощью весеннего облачного потока Кафка....

Я не могу настроить пользовательские обработчики для моего потребителя потока с помощью StreamsBuilderFactoryBeanCustomizer. @Bean public StreamsBuilderFactoryBeanCustomizer customizer() { return fb -> {...

У меня есть проект весенней загрузки с использованием Kafka. Я настроил его с помощью автоматической настройки Spring Cloud Stream Kafka. Я хочу создавать свои темы автоматически с 3 репликами и сроком хранения 1 день. Для этого я добавил...

Я использую Spring Cloud Stream 3.1.2 вместо KafkaStreams . Модели программирования: Функциональное программирование Императивное программирование Последний использует аннотации, как и все другие аннотации, которые Spring предоставляет...

Я пытаюсь перейти на новую модель функционального программирования для Spring Cloud Stream, заменив условные аннотации StreamListener, подобные этому @StreamListener("app-input", condition = "headers['eventName']=='Funded'")...