spring-boot - 将 Spring Integration Router 与 Spring Cloud Stream 一起使用

Question

我一直在尝试将 Spring Integration 的@Router与 Spring Cloud Stream 与 Kafka 绑定一起使用。我的理解是，当您List从带有注释的方法中返回一个通道名称时，@Router它们应该被生成到指定的 Kafka 主题中。但我没有看到正在生成的消息。

Spring Integration 是否@Router适用于 Spring Cloud Stream。如果没有，还有什么替代方法以及如何以编程方式路由到运行时选择的通道？

Answer 1

是什么让您相信 Spring Integration@Router对 Spring Cloud Stream 有任何影响？这是一个完全不同的框架。

是的，Spring Cloud Stream 中有路由 FROM 和 TO 的机制，它们在此处进行了描述。

我认为您的用例感兴趣的特定部分是Routing FROM，但请考虑阅读完整部分以了解所使用的差异和机制。