kafka+zookeeper偽叢集搭建
阿新 • • 發佈:2019-01-10
(一.zookeeper偽叢集搭建)1.建立3個zoo.cfg(zoo1.cfg,zoo2.cfg,zoo3.cfg)zoo1.cfg 設定:# 資料資料夾dataDir=/usr/local/zookeeper/data/data1# 日誌資料夾dataLogDir=/usr/local/zookeeper/logs/logs1clientPort=2181server.1=192.168.94.132:2887:3887server.2=192.168.94.132:2888:3888server.3=192.168.94.132:2889:3889zoo2.cfg 設定:# 資料資料夾dataDir=/usr/local/zookeeper/data/data2 # 日誌資料夾dataLogDir=/usr/local/zookeeper/logs/logs2clientPort=2182server.1=192.168.94.132:2887:3887server.2=192.168.94.132:2888:3888server.3=192.168.94.132:2889:3889zoo3.cfg 設定:# 資料資料夾dataDir=/usr/local/zookeeper/data/data3# 日誌資料夾dataLogDir=/usr/local/zookeeper/logs/logs2clientPort=2183server.1=192.168.94.132:2887:3887 server.2=192.168.94.132:2888:3888server.3=192.168.94.132:2889:38892.建立3個myid在usr/local/zookeeper/data/datax下闖進myid檔案作為識別符號,對應server.x數字3.啟動偽叢集服務 bin/zkServer.sh start conf/zoo1.cfgbin/zkServer.sh start conf/zoo2.cfgbin/zkServer.sh start conf/zoo3.cfg4.檢視偽叢集服務每個zookeeper狀態[[email protected] zookeeper-3.4.11]# bin/zkServer.sh status conf/zoo1.cfg ZooKeeper JMX enabled by defaultUsing config: conf/zoo1.cfgMode: follower[[email protected] zookeeper-3.4.11]# bin/zkServer.sh status conf/zoo2.cfgZooKeeper JMX enabled by defaultUsing config: conf/zoo2.cfgMode: leader[[email protected] zookeeper-3.4.11]# bin/zkServer.sh status conf/zoo3.cfgZooKeeper JMX enabled by defaultUsing config: conf/zoo3.cfgMode: follower(二.kafka偽叢集搭建)1. 將配置檔案拷貝多份[root@master zookeeper-3.4.11]$cp config/server.properties config/server-1.properties[root@master zookeeper-3.4.11]$cp config/server.properties config/server-2.properties[root@master zookeeper-3.4.11]$cp config/server.properties config/server-3.properties2.修改每個server-x.propertiesserver-1.properties 設定:broker.id=1port=9092host.name=192.168.94.132log.dirs=/usr/local/kafka/kafka-logs-1message.max.byte=5242880default.replication.factor=2replica.fetch.max.bytes=5242880zookeeper.connect=192.168.94.132:2181,192.168.94.132:2182,192.168.94.132:2183# 可刪除topicdelete.topic.enable=trueserver-2.properties 設定:broker.id=2port=9093host.name=192.168.94.132log.dirs=/usr/local/kafka/kafka-logs-2message.max.byte=5242880default.replication.factor=2replica.fetch.max.bytes=5242880zookeeper.connect=192.168.94.132:2181,192.168.94.132:2182,192.168.94.132:2183# 可刪除topicdelete.topic.enable=trueserver-3.properties 設定:broker.id=3port=9093host.name=192.168.94.132log.dirs=/usr/local/kafka/kafka-logs-3message.max.byte=5242880default.replication.factor=2replica.fetch.max.bytes=5242880zookeeper.connect=192.168.94.132:2181,192.168.94.132:2182,192.168.94.132:2183# 可刪除topicdelete.topic.enable=true每個kafka的broker.id不一樣,作為唯一識別符號