zookeeper 集群搭建
- tar zxvf zookeeper-3.4.14.tar.gz
- cd zookeeper-3.4.14/conf
- cp zoo_sample.cfg zoo.cfg
- vi zoo.cfg 在檔案末尾加上
server.1=192.168.1.1:3181:3182
server.2=192.168.1.2:3181:3182
server.3=192.168.1.3:3181:3182
說明： server.數字=IP:port1:port2 例如server.1=192.168.1.1:3181:3182
# server.A=B：C：D 其 中
# A 是一個數字，表示這個是第幾號服務器，叫做myid或sid；
# B 是這個服務器的 ip地址；
# C 表示的是這個服務器與集群中的 Leader 服務器交換資訊的埠；
# D 表示的是萬一集群中的 Leader 服務器掛了，需要一個埠來重新進行選舉，選出一個新的 Leader， 而這個埠就是用來執行選舉時服務器相互通信的埠，
即在192.168.1.1服務上
- cd /tem/zookeeper 目錄下
- vi myid 創建這個檔案該檔案填寫 數字 1
- 其他服務依此類推
- 啟動zookeeper
cd zookeeper/bin
sh zkServer.sh start
- 查看zookeeper狀態
進入到zookeeper安裝目錄
cd zookeeper-3.4.14/bin
sh zkServer.sh status
Kafka 集群搭建
-
tar zxvf kafka_2.11-2.3.1.tgz
-
cd kafka_2.11-2.3.1/config
-
vi server.properties 修改broker.id=數字 保證集群中此id唯一即可
修改listeners=PLAINTEXT://10.21.17.15:9092，此IP為當前服務器的IP， 修改 zookeeper鏈接，填寫zookeeper服務器的IP，埠默認是2181 -
啟動kafka cd kafka_2.11-2.3.1/bin sh kafka-server-start ../conf/server.propertis
Kafka基本指令使用
- 創建topic
sh kafka-topics.sh --create --zookeeper 192.168.1.1:2181,192.168.1.2:2181,192.168.1.3:2181 --replication-factor 2 --partitions 3 --topic zk_topic
--zookeeper 表示zookeeper服務器，多個服務器已英文逗號隔開 --replication-factor 表示用來設定主題的副本數 --partitions 物理意義上的topic磁區，可以在/tmp/kafka-logs下能看到zk_topic有3份
--topic topic主題名稱
-
查看已創建的topic sh kafka-topics.sh --list --zookeeper 192.168.1.1:2181,192.168.1.2:2181,192.168.1.3:2181
-
發送訊息 sh kafka-console-producer.sh --broker-list 192.168.1.1:9092 --topic zk_topic
-
消費訊息 sh kafka-console-consumer.sh --bootstrap-server 192.168.1.1:9092 --topic zk_topic --from-beginning
-
注意：很多人在學Java高級程序中難免會遇到各種問題解決不了，為此我建了個裙 783802103，里面很多架構師一起交流解答，沒基礎勿進哦！
本文的文字及圖片來源于網路加上自己的想法,僅供學習、交流使用,不具有任何商業用途,著作權歸原作者所有,如有問題請及時聯系我們以作處理
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/184523.html
標籤：Java