我有一个事件类。
class Event {
String destination;
}
目标属性是 Kafka 主题的名称。
如何将消息发布到目的地。
我不能把目的地放在 application.properties 因为目的地是在程序中设置的。
我有一个事件类。
class Event {
String destination;
}
目标属性是 Kafka 主题的名称。
如何将消息发布到目的地。
我不能把目的地放在 application.properties 因为目的地是在程序中设置的。
由于您动态确定目的地,因此您需要BinderAwareChannelResolver
在您的应用程序中。
类似于路由器接收器应用程序的东西。你可以检查