Kafka是由LinkedIn開發並開源的分散式訊息系統,因其分散式及高吞吐率而被廣泛使用,現已與Cloudera Hadoop,Apache Storm,Apache Spark整合，具備許多優秀的效能：高吞吐、分散式、跨平臺、實時性以及伸縮性，本文我們就來看看如何將Spring Cloud Bus和Kafka進行整合。

本文是Spring Cloud系列的第二十八篇文章，瞭解前二十七篇文章內容有助於更好的理解本文：

Kafka下載

Kafka現在是Apache上的開源專案，直接到官網下載即可(http://kafka.apache.org/)，這個不用我多說。

啟動

下載成功之後，是一個壓縮檔案，解壓該檔案，我們可以看到一個bin目錄，進入到bin目錄中，bin目錄下的.sh檔案都是Linux/Unix下的shell指令碼，在Linux/Unix環境下直接執行這些指令碼即可，bin目錄中還有一個windows目錄，該目錄下儲存的都是windows中的批處理檔案。我們在執行時根據自己的作業系統選擇合適的命令去執行，本文以windows為例。解壓後為了後面的命令操作方便，我將windows檔案配置到環境變數中，我的是D:\Program\kafka_2.11-0.11.0.1\bin\windows,然後在cmd中進入到解壓目錄下，執行zookeeper-server-start.bat .\config\zookeeper.properties

zookeeper在啟動的過程中需要用到zookeeper.properties配置檔案，這個檔案中定義了zookeeper的埠為2181。zookeeper啟動成功之後，接下來我們要啟動Kafka，執行kafka-server-start.bat .\config\server.properties命令，如下：

兩者都啟動成功之後，我們可以執行如下命令kafka-console-producer.bat --broker-list localhost:9092 --topic test

訊息傳送了，當然要有人來接收，接下來我們來建立訊息接收端，執行kafka-console-consumer.bat --zookeeper localhost:2181 --topic test --from-beginning命令，啟動成功之後，我們就可以收到剛剛傳送的訊息了，如下：

整合Spring Cloud Bus

Spring Cloud Bus和Kafka的整合非常簡單，如果我們使用了預設配置，就可以從RabbitMQ無縫切換過來，只需要修改一下我們之前config-server和config-client的依賴，將spring-cloud-starter-bus-amqp改為spring-cloud-starter-bus-kafka，如下：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-kafka</artifactId>
</dependency>

修改之後，我們分別啟動eureka、config-server和config-client，測試方式還是和上文一樣，該有的/bus/refresh介面的功能還是不變。這裡我就不再贅述了。

好了，Kafka我們就先說這麼多。有問題歡迎留言討論。

更多JavaEE資料請關注公眾號: