Springboot 1.5.7整合Kafka-client代碼示例
更新時間：2020年10月29日 11:52:41 作者：馬云12314
這篇文章主要介紹了Springboot 1.5.7整合Kafka-client代碼示例,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
在一次項目中，因甲方需要使用kafka消息隊列推送數(shù)據(jù)，所以需要接入kafka，并且kafka的版本是2.11。但是我們項目使用的是Springboot 1.5.7的版本，對應(yīng)的springboot.kafka.starter有沖突，所以就接入了kafka-client。
Kafka 是一個分布式消息引擎與流處理平臺，經(jīng)常用做企業(yè)的消息總線、實時數(shù)據(jù)管道，有的還把它當(dāng)做存儲系統(tǒng)來使用。
早期 Kafka 的定位是一個高吞吐的分布式消息系統(tǒng)，目前則演變成了一個成熟的分布式消息引擎，以及流處理平臺。
Kafka 主要起到削峰填谷（緩沖）、系統(tǒng)解構(gòu)以及冗余的作用，主要特點有：
- 高吞吐、低延時：這是 Kafka 顯著的特點，Kafka 能夠達(dá)到百萬級的消息吞吐量，延遲可達(dá)毫秒級；
- 持久化存儲：Kafka 的消息最終持久化保存在磁盤之上，提供了順序讀寫以保證性能，并且通過 Kafka 的副本機(jī)制提高了數(shù)據(jù)可靠性。
- 分布式可擴(kuò)展：Kafka 的數(shù)據(jù)是分布式存儲在不同 broker 節(jié)點的，以 topic 組織數(shù)據(jù)并且按 partition 進(jìn)行分布式存儲，整體的擴(kuò)展性都非常好。
- 高容錯性：集群中任意一個 broker 節(jié)點宕機(jī)，Kafka 仍能對外提供服務(wù)。
springboot接入kafka-client還是比較簡單的，這里只是做一個記錄。
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é)束-->
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
本文主要介紹了maven實現(xiàn)docker自動化部署插件的使用，分享給大家，感興趣的小伙伴們可以參考一下2021-06-06
Java中如何使用?byte?數(shù)組作為?Map?的?key
本文將討論在使用HashMap時，當(dāng)byte數(shù)組作為key時所遇到的問題及其解決方案，介紹使用String和List這兩種數(shù)據(jù)結(jié)構(gòu)作為臨時解決方案的方法，感興趣的朋友跟隨小編一起看看吧2023-06-06
這篇文章主要介紹了Netty中序列化的作用及自定義協(xié)議詳解,Netty自身就支持很多種協(xié)議比如Http、Websocket等等,但如果用來作為自己的RPC框架通常會自定義協(xié)議,所以這也是本文的重點,需要的朋友可以參考下2023-12-12
在java編寫過程中，我們會使用到各種各樣的表達(dá)式，在使用表達(dá)式的過程中，有哪些安全問題需要我們注意的呢？對java判斷integer是否為空相關(guān)知識感興趣的朋友一起來看看吧2023-02-02
springboot配置文件中敏感數(shù)據(jù)(賬號密碼)加密方式
這篇文章主要介紹了springboot配置文件中敏感數(shù)據(jù)(賬號密碼)加密方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-04-04
這篇文章主要介紹了Java變量與常量，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-04-04
SpringBoot項目設(shè)置斷點debug調(diào)試無效忽略web.xml問題的解決
這篇文章主要介紹了SpringBoot項目設(shè)置斷點debug調(diào)試無效忽略web.xml問題的解決，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-08-08
Springboot讀取templates文件html代碼實例
這篇文章主要介紹了Springboot讀取templates文件html代碼實例,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-04-04
使用SpringMVC響應(yīng)json格式返回的結(jié)果類型
這篇文章主要介紹了使用SpringMVC響應(yīng)json格式返回的結(jié)果類型，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-07-07
本文主要介紹了如何集成Redisson,包括環(huán)境配置、引入Redisson的依賴、添加Redisson的配置類以及Redisson的常見使用方法,在類中注入Redisson后,可以獲取鎖對象和使用,這些都是作者的個人經(jīng)驗,供讀者參考2024-10-10