Вставка темы в аннотацию @KafkaListener из другого класса конфигурации ⇐ JAVA
-
Гость
Вставка темы в аннотацию @KafkaListener из другого класса конфигурации
У меня есть класс конфигурации Java, говорящий вот так
@Configuration общественный класс MyConfig { @Value("${kafka.topic:default_topic}") Строка kafkaTopic; } И мой текущий KafkaListener имеет такую аннотацию
@KafkaListener(topics = "${kafka.topic}") public voidprocessMe(@Payload String msg) { Я хочу использовать метод получения из моего класса конфигурации и внедрить тему в KafkaListener. KafkaListener находится в отдельном классе
Как это возможно сделать?
У меня есть класс конфигурации Java, говорящий вот так
@Configuration общественный класс MyConfig { @Value("${kafka.topic:default_topic}") Строка kafkaTopic; } И мой текущий KafkaListener имеет такую аннотацию
@KafkaListener(topics = "${kafka.topic}") public voidprocessMe(@Payload String msg) { Я хочу использовать метод получения из моего класса конфигурации и внедрить тему в KafkaListener. KafkaListener находится в отдельном классе
Как это возможно сделать?
Мобильная версия