Использование Spring Integration Router с Spring Cloud Stream

Question

Я пытался использовать @ Router Spring Integration с Spring Cloud Stream с привязкой Kafka. Насколько я понимаю, когда вы возвращаете List имен каналов из метода, помеченного @Router, они должны быть получены в предназначенных темах Kafka. Но я не вижу сообщений, производимых.

Работает ли Spring Integration @Router с Spring Cloud Stream. Если нет, какова альтернатива и как программно маршрутизировать каналы, выбранные во время выполнения?

Answer 1

С чего вы взяли, что Spring Integration @Router оказывает какое-либо влияние на Spring Cloud Stream? Это совершенно другой фреймворк.

Да, есть механизмы для маршрутизации ОТ и ТО в Spring Cloud Stream, и они описаны здесь .

Я думаю, что специфика c Интересующий раздел для вашего варианта использования Маршрутизация ОТ , но вы можете прочитать полный раздел, чтобы понять различия и используемые механизмы.