Kafka學習總結(五)——Kafka叢集搭建
阿新 • • 發佈：2019-01-09
1、準備好kafka安裝包，unzip xxx.zip 解壓。
2、進入到kafka的config目錄
3、先搭建三個節點zk叢集，三臺機器。 修改zookeeper.properties如下配置資訊。
cd /home/xxx/data/zookeeper 目錄
每臺機器都需要建立myid檔案，內容依次為1，2，3
如下是3臺叢集伺服器樣例：
4、三臺機器都修改好zookeeper.properties檔案和建立好myid檔案 進入kafka目錄
執行啟動zookeeper命令：nohup ./bin/zookeeper-server-start.sh config/zookeeper.properties >logs/zookeeper.log 2>1
& 
三臺機器都執行啟動命令，檢視logs/zookeeper.log 檔案，沒有報錯就說明zookeeper叢集啟動成功了。 5、著手搭建kafka叢集 修改server.properties配置檔案，三個配置相應修改。 host.name 為各機器的IP地址
配置檔案最下方：
5、啟動kafka三個節點 進入kafka目錄，執行如下命令 nohup ./bin/kafka-server-start.sh config/server.properties >logs/kafka.log 2>1 & 6、測試kafka叢集 1-進入kafka根目錄，建立topic--test bin/kafka-topics.sh --create --zookeeper 192.168.1.xx:2181,192.168.1.xx:2181,192.168.1.xx:2181 --replication-factor 1 --partitions 1 --topic test 
2-列出已建立的topic列表 bin/kafka-topics.sh --list --zookeeper localhost:2181 3-模擬客戶端去傳送訊息 bin/kafka-console-producer.sh --broker-list 192.168.1.xx:9092,192.168.1.xx:9092,192.168.1.xx:9092 --topic test
4-模擬客戶端去接受訊息 bin/kafka-console-consumer.sh --zookeeper 192.168.1.xx:2181,192.168.1.xx:2181,192.168.1.xx:2181 --from-beginning --topic test 
7、自己測試結果
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 1 --topic test
2、進入到kafka的config目錄
3、先搭建三個節點zk叢集，三臺機器。 修改zookeeper.properties如下配置資訊。
cd /home/xxx/data/zookeeper 目錄
每臺機器都需要建立myid檔案，內容依次為1，2，3
如下是3臺叢集伺服器樣例：
4、三臺機器都修改好zookeeper.properties檔案和建立好myid檔案 進入kafka目錄
執行啟動zookeeper命令：nohup ./bin/zookeeper-server-start.sh config/zookeeper.properties >logs/zookeeper.log 2>1
&三臺機器都執行啟動命令，檢視logs/zookeeper.log 檔案，沒有報錯就說明zookeeper叢集啟動成功了。 5、著手搭建kafka叢集 修改server.properties配置檔案，三個配置相應修改。 host.name 為各機器的IP地址
配置檔案最下方：
5、啟動kafka三個節點 進入kafka目錄，執行如下命令 nohup ./bin/kafka-server-start.sh config/server.properties >logs/kafka.log 2>1 & 6、測試kafka叢集 1-進入kafka根目錄，建立topic--test bin/kafka-topics.sh --create --zookeeper 192.168.1.xx:2181,192.168.1.xx:2181,192.168.1.xx:2181 --replication-factor 1 --partitions 1 --topic test
2-列出已建立的topic列表 bin/kafka-topics.sh --list --zookeeper localhost:2181 3-模擬客戶端去傳送訊息 bin/kafka-console-producer.sh --broker-list 192.168.1.xx:9092,192.168.1.xx:9092,192.168.1.xx:9092 --topic test
4-模擬客戶端去接受訊息 bin/kafka-console-consumer.sh --zookeeper 192.168.1.xx:2181,192.168.1.xx:2181,192.168.1.xx:2181 --from-beginning --topic test
7、自己測試結果
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 1 --topic test