Springboot 1.5.7整合Kafka-client代碼示例
在一次項(xiàng)目中，因甲方需要使用kafka消息隊(duì)列推送數(shù)據(jù)，所以需要接入kafka，并且kafka的版本是2.11。但是我們項(xiàng)目使用的是Springboot 1.5.7的版本，對(duì)應(yīng)的springboot.kafka.starter有沖突，所以就接入了kafka-client。
Kafka 是一個(gè)分布式消息引擎與流處理平臺(tái)，經(jīng)常用做企業(yè)的消息總線、實(shí)時(shí)數(shù)據(jù)管道，有的還把它當(dāng)做存儲(chǔ)系統(tǒng)來(lái)使用。
早期 Kafka 的定位是一個(gè)高吞吐的分布式消息系統(tǒng)，目前則演變成了一個(gè)成熟的分布式消息引擎，以及流處理平臺(tái)。
Kafka 主要起到削峰填谷（緩沖）、系統(tǒng)解構(gòu)以及冗余的作用，主要特點(diǎn)有：
- 高吞吐、低延時(shí)：這是 Kafka 顯著的特點(diǎn)，Kafka 能夠達(dá)到百萬(wàn)級(jí)的消息吞吐量，延遲可達(dá)毫秒級(jí)；
- 持久化存儲(chǔ)：Kafka 的消息最終持久化保存在磁盤之上，提供了順序讀寫以保證性能，并且通過(guò) Kafka 的副本機(jī)制提高了數(shù)據(jù)可靠性。
- 分布式可擴(kuò)展：Kafka 的數(shù)據(jù)是分布式存儲(chǔ)在不同 broker 節(jié)點(diǎn)的，以 topic 組織數(shù)據(jù)并且按 partition 進(jìn)行分布式存儲(chǔ)，整體的擴(kuò)展性都非常好。
- 高容錯(cuò)性：集群中任意一個(gè) broker 節(jié)點(diǎn)宕機(jī)，Kafka 仍能對(duì)外提供服務(wù)。
springboot接入kafka-client還是比較簡(jiǎn)單的，這里只是做一個(gè)記錄。
pom文件中添加如下依賴即可
<!-- kafka集成 開始-->
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>2.0.1</version>
</dependency>
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
<version>1.1.8.RELEASE</version>
<exclusions>
<exclusion>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
</exclusion>
</exclusions>
</dependency>
<!-- kafka集成 結(jié)束-->
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要介紹了Java 線程的相關(guān)資料，幫助大家更好的理解和學(xué)習(xí)使用Java，感興趣的朋友可以了解下2021-02-02
Spring boot 在idea中添加熱部署插件的圖文教程
這篇文章主要介紹了Spring boot 在idea中添加熱部署插件的圖文教程,本文通過(guò)圖文并茂的形式給大家展示具體步驟，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2021-10-10
詳解@ConfigurationProperties實(shí)現(xiàn)原理與實(shí)戰(zhàn)
這篇文章主要介紹了詳解@ConfigurationProperties實(shí)現(xiàn)原理與實(shí)戰(zhàn)，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-10-10
使用?mybatis?自定義日期類型轉(zhuǎn)換器的示例代碼
這篇文章主要介紹了使用?mybatis?自定義日期類型轉(zhuǎn)換器的示例代碼，這里使用mybatis中的typeHandlers?實(shí)現(xiàn)的，本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì)，需要的朋友可以參考下2022-03-03
這篇文章主要為大家分享了Java面試資源下篇，百度“Java面試題”前200頁(yè)都在這里了，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-12-12
JavaWeb實(shí)現(xiàn)用戶登錄與注冊(cè)功能
這篇文章主要為大家詳細(xì)介紹了JavaWeb實(shí)現(xiàn)用戶登錄與注冊(cè)功能，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2021-08-08
java文字轉(zhuǎn)語(yǔ)音的實(shí)現(xiàn)示例
在Java中,我們可以使用第三方庫(kù)來(lái)實(shí)現(xiàn)文字轉(zhuǎn)語(yǔ)音的功能,本文主要介紹了java文字轉(zhuǎn)語(yǔ)音的實(shí)現(xiàn)示例,選擇jacob技術(shù)實(shí)現(xiàn),具有一定的參考價(jià)值,感興趣的可以了解一下2024-03-03
Java實(shí)現(xiàn)簡(jiǎn)單的貪吃蛇游戲
這篇文章主要介紹了Java實(shí)現(xiàn)簡(jiǎn)單的貪吃蛇游戲，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2021-07-07
Java項(xiàng)目中如何訪問WEB-INF下jsp頁(yè)面
這篇文章主要介紹了Java項(xiàng)目中如何訪問WEB-INF下jsp頁(yè)面，文章通過(guò)示例代碼和圖文解析介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-08-08
Java 實(shí)現(xiàn)將List平均分成若干個(gè)集合
這篇文章主要介紹了Java 實(shí)現(xiàn)將List平均分成若干個(gè)集合，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2020-08-08