SpringBoot整合kafka集群

2021-10-25 14:28:58 字數 2176 閱讀 2852

本文整合基於springboot2.0+,kafka版本kafka_2.12-2.3.0,使用org.springframework.kafka來做的整合

專案目錄結構

pom.xml依賴

本配置檔案是才用的併發批量消費方式, bootstrap-servers是我們集群的機器位址

生產者controller
@restcontroller

@slf4j

public class producercontroller

}

消費者***
@component

@slf4j

public class consumerlistener )}

@kafkalistener(topics = "test", groupid = "consumer-group")

public void listen(listlist, acknowledgment ack)

if (msglist.size() > 0)

// 更新索引

// updatees(messages);

}//手動提交offset

ack.acknowledge();

msglist.clear();

log.info("消費結束");

}}

我們的消費者***才用的併發批量下拉資料 才用手動提交方式避免訊息丟失

啟動類

public static void main(string args) }

啟動程式並且生產訊息

通啟動日誌我們可以看到我們成功連線到kafka集群

kafka生產和消費日誌資訊

這裡我們也可以通過批量生產訊息 改變配置檔案的併發引數和批量下拉引數來做批量併發消費

我們這裡topic設定的為test groupid為consumer-group

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...