Springboot 1.5.7整合Kafka-client代碼示例
在一次項目中,因甲方需要使用kafka消息隊列推送數(shù)據(jù),所以需要接入kafka,并且kafka的版本是2.11。但是我們項目使用的是Springboot 1.5.7的版本,對應(yīng)的springboot.kafka.starter有沖突,所以就接入了kafka-client。
Kafka 是一個分布式消息引擎與流處理平臺,經(jīng)常用做企業(yè)的消息總線、實時數(shù)據(jù)管道,有的還把它當做存儲系統(tǒng)來使用。
早期 Kafka 的定位是一個高吞吐的分布式消息系統(tǒng),目前則演變成了一個成熟的分布式消息引擎,以及流處理平臺。
Kafka 主要起到削峰填谷(緩沖)、系統(tǒng)解構(gòu)以及冗余的作用,主要特點有:
- 高吞吐、低延時:這是 Kafka 顯著的特點,Kafka 能夠達到百萬級的消息吞吐量,延遲可達毫秒級;
- 持久化存儲:Kafka 的消息最終持久化保存在磁盤之上,提供了順序讀寫以保證性能,并且通過 Kafka 的副本機制提高了數(shù)據(jù)可靠性。
- 分布式可擴展:Kafka 的數(shù)據(jù)是分布式存儲在不同 broker 節(jié)點的,以 topic 組織數(shù)據(jù)并且按 partition 進行分布式存儲,整體的擴展性都非常好。
- 高容錯性:集群中任意一個 broker 節(jié)點宕機,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)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
Spring boot 在idea中添加熱部署插件的圖文教程
這篇文章主要介紹了Spring boot 在idea中添加熱部署插件的圖文教程,本文通過圖文并茂的形式給大家展示具體步驟,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2021-10-10
詳解@ConfigurationProperties實現(xiàn)原理與實戰(zhàn)
這篇文章主要介紹了詳解@ConfigurationProperties實現(xiàn)原理與實戰(zhàn),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2020-10-10
使用?mybatis?自定義日期類型轉(zhuǎn)換器的示例代碼
這篇文章主要介紹了使用?mybatis?自定義日期類型轉(zhuǎn)換器的示例代碼,這里使用mybatis中的typeHandlers?實現(xiàn)的,本文通過實例代碼給大家介紹的非常詳細,需要的朋友可以參考下2022-03-03

