我需要有关Spring应用程序配置文件的帮助。
我的配置看起来是这样的:
integration
mapping:
- producer:
name: somename
topic: sometopic
replyTopic: sometopic
replyPartition: 1
consumer:
name: somename
field_1: ...
field_2: ...
- producer:
name: somename
topic: sometopic
replyTopic: sometopic
replyPartition: 1
consumer:
name: somename
field_1: ...
field_2: ...
我需要从这个配置中提取所有字段“replyTopic”。我知道我可以用ConfigurationProperties注解将所有这些配置Map到类,但我只想将replyTopic字段放在@KafkaListener注解中,这需要在应用程序启动时获取主题名称。
所以基本上我想要这样的东西:
@KafkaListener(topics = '*some expression to extract all of replyTopic from congiration*')
谢谢你!
1条答案
按热度按时间h5qlskok1#
您可以使用
@ConfigurationProperties
注解本身来实现这一点。第一个问题:
输出
[某主题1,某主题2]