我要评论项目场景
在spring kafka中，我们可以使用${}来引用spring的属性配置。
这样我们就可以在不同的环境中重新配置topic名称，而不需要修改代码。
解决方案
- 在application.properties或application.yml中定义topic名称：
# application.properties kafka.topic=mytopic
- 然后在你的代码中使用
${}来引用这个属性：
@kafkalistener(topics = "${kafka.topic}")
public void listen(string message) {
system.out.println("received message in topic : " + message);
}- 如果你使用的是多个topic
- 你可以使用
;来分割多个topic名称：
# application.properties kafka.topics=topic1;topic2;topic3
- 然后在你的代码中使用
${}来引用这个属性：
@kafkalistener(topics = "${kafka.topics}")
public void listen(string message) {
system.out.println("received message in topic : " + message);
}总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持代码网。
发表评论