spring boot 整合多個kafka集群

2021-09-20 06:24:56 字數 1164 閱讀 2275

有時候我們的整合軟體需要在專案中整合多個kafka集群，實現步驟如下：

步驟一：配置第二個kafka檔案

步驟二：定義第二個kafka的實現類

/**


* @description: 


* @project: 


* @createdate: created in 2019/4/26 18:20 


* @author: xiaozm


*/@configuration


@propertysource("classpath:config/kafka1.properties")


//@enablekafka


public class kafkacarconsumerconfig ")


private string servers;


@value("$")


private boolean enableautocommit;


@value("$")


private string sessiontimeout;


@value("$")


private string autocommitinterval;


@value("$")


private string groupid;


@value("$")


private string autooffsetreset;


@bean


public kafkalistenercontaine***ctory> kafkacarlistenercontaine***ctory() 


public consume***ctoryconsumerca***ctory() 


public mapconsumercarconfigs() 


}
步驟三：實現資料的監聽（注意：containe***ctory的值必須和第二步驟中的bean名稱一致）

springBoot整合dubbo整合專案

傳統spring 整合dubbo，需要繁瑣的編寫一堆堆的 xml 配置檔案 而springboot整合dubbo後，不在需要寫 xml,通過jar包引用，完 成整合，通過註解的形式完成配置。提高我們的開發效率 目錄結構 1 服務層生產者開發 hs ldm server service 1.1新增du...

SpringBoot整合系列 整合Swagger2

io.springfox springfox swagger2 2.7.0 io.springfox springfox swagger ui 2.7.0 一般無配置項，必要時可以新增自定義配置項，在配置類中讀取 swagger2的配置內容僅僅就是需要建立乙個docket例項 configurati...

SpringBoot整合PageHelper外掛程式

springboot整合pagehelper外掛程式的時候主要分為以下幾步?1.在pom.xml中引入依賴 com.github.pagehelper pagehelper spring boot starter 1.2.3 分頁外掛程式 pagehelper.helperdialect mysql...