Java架構-KafKa叢集安裝詳細步驟
最近在使用Spring Cloud進行分散式微服務搭建，順便對整合KafKa的方案做了一些總結，今天詳細介紹一下KafKa叢集安裝過程：
1.在根目錄建立kafka資料夾（service1、service2、service3都建立）
[[email protected] /]# mkdir kafka
2.通過Xshell上傳檔案到service1伺服器：上傳kafka_2.9.2-0.8.1.1.tgz到/software資料夾
3.遠端copy將service1下的/software/kafka_2.9.2-0.8.1.1.tgz到service2、service3
[[email protected] software]# scp -r /software/kafka_2.9.2-0.8.1.1.tgz [email protected]:/software/
[[email protected] software]# scp -r /software/kafka_2.9.2-0.8.1.1.tgz [email protected]:/software/
3.copy /software/kafka_2.9.2-0.8.1.1.tgz到/kafka/目錄（service1、service2、service3都執行）
4.安裝解壓kafka_2.9.2-0.8.1.1.tgz（service1、service2、service3都執行）
[[email protected] /]# cd /kafka/
[[email protected] kafka]# tar -zxvf kafka_2.9.2-0.8.1.1.tgz
5.建立kafka訊息目錄（service1,service2,service3都要建立）
[[email protected] kafka]# mkdir kafkaLogs
6. 修改kafka的配置檔案（service1,service2,service3都要配置）
[[email protected] /]# cd /kafka/kafka_2.9.2-0.8.1.1/
[[email protected] kafka_2.9.2-0.8.1.1]# cd config/
[[email protected] config]# ls
consumer.properties log4j.properties producer.properties server.properties test-log4j.properties tools-log4j.properties zookeeper.properties
[[email protected] config]# vi server.properties
7.啟動kafka服務
[[email protected] bin]# ./kafka-server-start.sh -daemon …/config/server.properties
[[email protected] bin]# jps
27413 Kafka
27450 Jps
17884 QuorumPeerMain
8.驗證kafka叢集
[[email protected] bin]# ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 1 --topic test
Created topic “test”.
9.在service1上開啟producer程式
./kafka-console-producer.sh --broker-list 192.168.2.211:9092 --topic test
[[email protected] bin]# ./kafka-console-producer.sh --broker-list 192.168.2.211:9092 --topic test
SLF4J: Failed to load class “org.slf4j.impl.StaticLoggerBinder”.
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
10. 在service2上開啟consumer程式
[[email protected] bin]# ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
SLF4J: Failed to load class “org.slf4j.impl.StaticLoggerBinder”.
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
11.在producer中傳送訊息：hello honghu
[[email protected] bin]# ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
SLF4J: Failed to load class “org.slf4j.impl.StaticLoggerBinder”.
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
hello honghu
12. 在consumer中接受到訊息
[[email protected] bin]# ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
SLF4J: Failed to load class “org.slf4j.impl.StaticLoggerBinder”.
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
hello honghu
我本人邀約各大BATJ架構大牛共創Java架構師社群群，（群號：673043639）致力於免費提供Java架構行業交流平臺，通過這個平臺讓大家相互學習成長，提高技術，讓自己的水平進階一個檔次，成功通往Java架構技術大牛或架構師發展
為什麼某些人會一直比你優秀，是因為他本身就很優秀還一直在持續努力變得更優秀，而你是不是還在滿足於現狀內心在竊喜!
合理利用自己每一分每一秒的時間來學習提升自己，不要再用"沒有時間“來掩飾自己思想上的懶惰！趁年輕，使勁拼，給未來的自己一個交代！
希望此文能幫到大家的同時，也聽聽大家的觀點。歡迎留言討論，加關注，分享你的高見！持續更新！
To-陌霖Java架構
分享網際網路最新文章 關注網際網路最新發展