1

我有一个事件类。

class Event {
    String destination;
}

目标属性是 Kafka 主题的名称。

如何将消息发布到目的地。

我不能把目的地放在 application.properties 因为目的地是在程序中设置的。

4

1 回答 1

0

由于您动态确定目的地,因此您需要BinderAwareChannelResolver在您的应用程序中。

类似于路由器接收器应用程序的东西。你可以检查

于 2016-04-06T04:59:26.263 回答