将 Spring Integration Router 与 Spring Cloud Stream 结合使用

Using Spring Integration Router with Spring Cloud Stream

我一直在尝试将 Spring 集成的 @Router 与 Spring Cloud Stream 与 Kafka 绑定结合使用。我的理解是,当您 return 来自用 @Router 注释的方法的 List 通道名称时,它们应该被生成到指定的 Kafka 主题。但我没有看到正在生成的消息。

Spring 集成的 @Router 是否与 Spring Cloud Stream 一起使用。如果不是,有什么替代方案以及如何以编程方式路由到运行时选择的频道?

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

是的,在 Spring Cloud Stream 中有路由 FROM 和 TO 的机制,它们被描述为 here

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