SpringBoot中@KafkaListener使用${}動(dòng)態(tài)指定topic問(wèn)題

更新時(shí)間：2024年12月12日 14:22:47 作者：濤哥是個(gè)大帥比

在SpringKafka中,使用${}引用Spring屬性配置,可以在不同環(huán)境中重新配置topic名稱(chēng),而無(wú)需修改代碼,在application.properties或application.yml中定義topic名稱(chēng),并在代碼中使用${}引用

項(xiàng)目場(chǎng)景

在Spring Kafka中，我們可以使用${}來(lái)引用Spring的屬性配置。

這樣我們就可以在不同的環(huán)境中重新配置topic名稱(chēng)，而不需要修改代碼。

解決方案

在application.properties或application.yml中定義topic名稱(chēng)：

# application.properties
kafka.topic=myTopic

然后在你的代碼中使用${}來(lái)引用這個(gè)屬性：

@KafkaListener(topics = "${kafka.topic}")
public void listen(String message) {
    System.out.println("Received message in topic : " + message);
}

如果你使用的是多個(gè)topic
你可以使用;來(lái)分割多個(gè)topic名稱(chēng)：

# application.properties
kafka.topics=topic1;topic2;topic3

然后在你的代碼中使用${}來(lái)引用這個(gè)屬性：

@KafkaListener(topics = "${kafka.topics}")
public void listen(String message) {
    System.out.println("Received message in topic : " + message);
}

總結(jié)

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章:

相關(guān)文章

簡(jiǎn)單工廠(chǎng)模式_動(dòng)力節(jié)點(diǎn)Java學(xué)院整理
這篇文章主要介紹了簡(jiǎn)單工廠(chǎng)模式的相關(guān)資料，和大家一起學(xué)習(xí)靜態(tài)工廠(chǎng)方法模式，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
2017-08-08
springboot使用nacos的示例詳解
這篇文章主要介紹了springboot使用nacos的示例代碼，本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
2021-12-12
springboot實(shí)現(xiàn)配置多個(gè)yml文件
文章主要介紹了在Spring Boot項(xiàng)目中實(shí)現(xiàn)多環(huán)境配置的三種方式：方式一、多YAML文件配置；方式二、單YAML文件配置；方式三、在pom.xml中指定環(huán)境配置,每種方式都有其特點(diǎn)和適用場(chǎng)景
2025-11-11
Java并發(fā)編程之同步容器
這篇文章主要介紹了Java并發(fā)編程之同步容器,文中有非常詳細(xì)的代碼示例,對(duì)正在學(xué)習(xí)java的小伙伴們有很好的幫助,需要的朋友可以參考下
2021-05-05
java之向linux文件夾下寫(xiě)文件無(wú)權(quán)限的問(wèn)題
這篇文章主要介紹了java之向linux文件夾下寫(xiě)文件無(wú)權(quán)限的問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
2023-09-09
Java手動(dòng)配置線(xiàn)程池過(guò)程詳解
這篇文章主要介紹了Java手動(dòng)配置線(xiàn)程池過(guò)程詳解,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
2020-05-05
Java單鏈表基本操作的實(shí)現(xiàn)
鏈表是一種數(shù)據(jù)結(jié)構(gòu)，和數(shù)組同級(jí)。接下來(lái)通過(guò)本文給大家介紹Java單鏈表基本操作的實(shí)現(xiàn)，非常不錯(cuò)，具有參考借鑒價(jià)值，感興趣的朋友一起看下吧
2016-07-07
JVM性能調(diào)優(yōu)實(shí)現(xiàn)原理及配置
這篇文章主要介紹了JVM性能調(diào)優(yōu)實(shí)現(xiàn)原理及配置,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
2020-12-12
詳解在Spring Boot框架下使用WebSocket實(shí)現(xiàn)消息推送
這篇文章主要介紹了詳解在Spring Boot框架下使用WebSocket實(shí)現(xiàn)消息推送,具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下。
2016-12-12
java為什么不建議用equals判斷對(duì)象相等
本文主要介紹了java為什么不建議用equals判斷對(duì)象相等，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
2023-03-03