Spring Cloud Stream动态频道

Question

我正在使用Spring Cloud Stream，并想以编程方式创建和绑定频道。我的用例是，在应用程序启动期间，我会收到要订阅的Kafka主题的动态列表。然后如何为每个主题创建频道？

Answer 1

对于传入消息，您可以显式使用BinderAwareChannelResolver动态解析目标。您可以检查此示例，其中router接收器使用绑定器感知通道解析器。