您好,登錄后才能下訂單哦!
搭建 Pulsar 集群需要 3 個(gè)組件:ZooKeeper 集群、BookKeeper 集群和 broker 集群
以下部署策略:
192.168.1.46 (部署B(yǎng)ookKeeper,部署broker)
192.168.1.47 (部署B(yǎng)ookKeeper,部署broker)
192.168.1.48 (部署單個(gè)ZK,部署B(yǎng)ookKeeper,部署broker)
前期準(zhǔn)備
1)jdk1.8
2)在各機(jī)器根下創(chuàng)建 data目錄,下載apache-pulsar-2.4.2-bin.tar.gz拷到data目錄下
chmod 777 apache-pulsar-2.4.2-bin.tar.gz
tar xvfz apache-pulsar-2.4.2-bin.tar.gz
一 ZooKeeper 集群
為了簡(jiǎn)單一臺(tái)機(jī)器上部署單個(gè)ZK使用.
1) 在data目錄下創(chuàng)建 zookeeper和zookeeper/logs目錄
2) 修改 zookeeper.conf 文件
dataDir=/data/zookeeper
dataLogDir=/data/zookeeper/logs
server.3=192.168.1.48:2888:3888
3) 執(zhí)行命令 echo 3 > /data/zookeeper/zookeeper/myid
4) 啟動(dòng)zk
/data/apache-pulsar-2.4.2$ PULSAR_EXTRA_OPTS="-Dstats_server_port=8001" bin/pulsar-daemon start zookeeper
(注意:因?yàn)閆K和broker部署在同一機(jī)器啟動(dòng)時(shí)要加上PULSAR_EXTRA_OPTS="-Dstats_server_port=8001" 改變端口,否則到后邊在沖突)
5) 初始化集群元數(shù)據(jù)
bin/pulsar initialize-cluster-metadata \
--cluster pulsar-cluster-zk \
--zookeeper 192.168.1.48:2181 \
--configuration-store 192.168.1.48:2181 \
--web-service-url http://192.168.1.48:8080 \
--web-service-url-tls https://192.168.1.48:8443 \
--broker-service-url pulsar://192.168.1.48:6650 \
--broker-service-url-tls pulsar+ssl://192.168.1.48:6651
二 BookKeeper 集群
1)創(chuàng)建 /data/bookkeeper/目錄
2)bookkeeper.conf 文件
advertisedAddress=HOSTNAMEIP (根據(jù)機(jī)器IP填寫(xiě))
zkServers=192.168.1.48:2181
journalDirectory=/data/bookkeeper/journal
ledgerDirectories=/data/bookkeeper/ledgers
3 執(zhí)行初始化元數(shù)據(jù)命令;若出現(xiàn)提示,輸入 Y,繼續(xù)(只需在一個(gè)bookie節(jié)點(diǎn)執(zhí)行一次)
/data/apache-pulsar-2.4.2$ bin/bookkeeper shell metaformat
4)啟動(dòng) data/apache-pulsar-2.4.2$ bin/pulsar-daemon start bookie
5)另兩臺(tái)機(jī)器根據(jù)以上操作分別啟動(dòng)
三部署 broker集群
1 修改配置文件broker.conf
zookeeperServers=192.168.1.48:2181
configurationStoreServers=192.168.1.48:2181
advertisedAddress=HOSTNAME (根據(jù)機(jī)器IP填寫(xiě))
clusterName=pulsar-cluster-zk
2 啟動(dòng)data/apache-pulsar-2.4.2$ bin/pulsar-daemon start broker
3 另兩臺(tái)機(jī)器根據(jù)以上操作分別啟動(dòng)
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。