SpringBoot中使用@KafkaListener如何动态指定topic
背景: 在公司的SpringBoot项目中使用注解 @org.springframework.kafka.annotation.KafkaListener 的时候,kafka的topic可以使用注解中的topics属性自行设定,但是问题是,公司在每个环境的topicName不一样,项目的结构是SpringBoot在启动的时候会读取相应环境(int、uat、pro)的yml文件,所以现在的问题是..
·
背景: 在公司的SpringBoot项目中使用注解 @org.springframework.kafka.annotation.KafkaListener 的时候,kafka的topic可以使用注解中的topics属性自行设定,但是问题是,公司在每个环境的topicName不一样,项目的结构是SpringBoot在启动的时候会读取相应环境(int、uat、pro)的yml文件,所以现在的问题是需要在启动的时候,根据环境变量的输入来决定监听哪个topic.
正常使用的方式可能是如下的样子:
@KafkaListener(topics = "myTopic")
public void process(String content) {
//TODO
}
那么怎么让myTopic变成动态输入的呢?
可以在yml配置文件中新增配置: topicName: defaultname
修改原先的代码为:
@KafkaListener(topics = "${topicName}")
public void process(String content) {
//TODO
}
这样就可以了。
更多推荐
已为社区贡献3条内容
所有评论(0)