Как выбрать тему Кафки динамически с помощью Spring Cloud Stream

Question

У меня есть класс Event.

class Event { 
    String destination; 
} 

Объект назначения - название темы Кафка.

Как я могу опубликовать сообщение в пункт назначения.

Я не могу поместить пункт назначения в application.properties, потому что пункт назначения был установлен в программе.

Answer 1

Поскольку вы определяете место назначения динамически, вам понадобится BinderAwareChannelResolver в вашем приложении.

Нечто похожее на router sink приложение. Вы можете проверить