在一次項(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í)有所幫助，也希望大家多多支持好吧啦網(wǎng)。