# Linux用户安装的程序一般放在 /usr/local/下
tar zxcf jdk-8u181-linux-x64.tar.gz, 解压安装包到 /usr/local/下
vi /etc/profile
export JAVA_HOME=/usr/local/jdk1.8.0_271
export JRE_HOME=/usr/local/jdk1.8.0_271/jre
export CLASS_PATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$JRE_HOME/lib
export PATH=$PATH:$JAVA_HOME/bin:$JRE_HOME/bin
source /etc/profile
alternatives --config java
alternatives --install /usr/bin/java java /usr/local/jdk1.8.0_181/bin/java 4
---
cp -ir /home/admin/apache-pulsar-2.x.x/* /home/admin/zookeepers/
cp -ir /home/admin/apache-pulsar-2.x.x/* /home/admin/brokers/
cp -ir /home/admin/apache-pulsar-2.x.x/* /home/admin/bookies/
---
# zookeeper
/home/pulsar/data/zookeeper/data
mkdir -p data/zookeeper
vi /home/admin/zookeepers/conf/zookeeper.conf
server.1=10.57.98.208:2888:3888
server.2=10.57.98.209:2888:3888
server.3=10.57.98.210:2888:3888
---
cd /home/admin/zookeepers
## 初始化数据
bin/pulsar initialize-cluster-metadata
--cluster pulsar-cluster \
--zookeeper 10.57.98.210:2181 \
--configuration-store 10.57.98.210:2181 \
--web-service-url http://10.57.98.208:8080,10.57.98.209:8080,10.57.98.210:8080 \
--web-service-url-tls https://10.57.98.208:8443,10.57.98.209:8443,10.57.98.210:8443 \
--broker-service-url pulsar://10.57.98.208:6650,10.57.98.209:6650,10.57.98.210:6650 \
--broker-service-url-tls pulsar+ssl://10.57.98.208:6651,10.57.98.209:6651,10.57.98.210:6651
bin/pulsar zookeeper-shell
----
cd /home/admin/bookies/conf
修改配置文件 bookkeeper.conf。
# 进入bookie 配置文件目录
cd /home/admin/bookies/conf
# 编辑 bookkeeper.conf 文件
vim bookkeeper.conf
# advertisedAddress 修改为服务器对应的ip,在另外两台服务器也做对应的修改
advertisedAddress=10.57.98.208
advertisedAddress=10.57.98.209
advertisedAddress=10.57.98.210
# 修改以下两个文件目录地址
journalDirectories=/home/admin/bookies/tmp/journal
ledgerDirectories=/home/admin/bookies/tmp/ledger
# 修改zk地址和端口信息
zkServers=10.57.98.208:2181,10.57.98.209:2181,10.57.98.210:2181
prometheusStatsHttpPort=8100
bin/bookkeeper shell bookiesanity
bin/pulsar-daemon start bookie
bin/pulsar-daemon stop bookie
$ bin/bookkeeper shell simpletest --ensemble <num-bookies> --writeQuorum <num-bookies> --ackQuorum <num-bookies> --numEntries <num-entries>
# Broker集群部署
zookeeperServers=10.57.98.208:2181,10.57.98.209:2181,10.57.98.210:2181
configurationStoreServers=10.57.98.208:2181,10.57.98.209:2181,10.57.98.210:2181
advertisedAddress=10.57.98.208
advertisedAddress=10.57.98.209
advertisedAddress=10.57.98.210
--cluster pulsar-cluster \
clusterName=pulsar-cluster
bin/pulsar-daemon start broker
## 查看集群 brokers 节点情况
bin/pulsar-admin brokers list pulsar-cluster
BookKeeper 之 journal,ledger 文件路径优雅切换,不可直接修改重启,不可直接操作 zk 元数据
(1)关闭自动复制,关闭 bookie
bin/bookkeeper shell autorecovery -disable
bin/pulsar-daemon stop bookie
(2)获取当前 bookie 的 {instanceId}
bin/bookkeeper shell whatisinstanceid
(3)修改文件路径
/home/pulsar/data/bookkeeper/journal
journalDirectory=/home/pulsar/data/bookkeeper/journal
ledgerDirectories=/home/pulsar/data/bookkeeper/ledgers
(4)生成cookie 文件({instanceId},bookie的{ip:port},g-cookie-file 生成的文件名)
bin/bookkeeper shell cookie_generate -i f21c435f-25da-4a19-867c-f73eb1ded761 -j /home/pulsar/data/bookkeeper/journal -l /home/pulsar/data/bookkeeper/ledgers -o g-cookie-file 10.57.98.208:3181
(5)cookie 文件copy,与cookie更新
cp ./g-cookie-file /home/pulsar/data/bookkeeper/journal/current/VERSION
cp ./g-cookie-file /home/pulsar/data/bookkeeper/ledgers/current/VERSION
#cookie 更新
bin/bookkeeper shell cookie_update -cf g-cookie-file 10.57.98.208:3181
(7)bookie 做启动
ps -aux|grep BookieServer
ps -aux|grep BookkeperServer
bin/pulsar-daemon start zookeeper
bin/pulsar zookeeper-shell
bin/pulsar-daemon stop zookeeper
初始化命令
bin/bookkeeper shell metaformat
bin/pulsar-daemon start bookie
bin/bookkeeper shell bookiesanity
bin/pulsar-daemon stop bookie
bin/pulsar-daemon start broker
bin/pulsar-daemon stop broker
bin/pulsar-admin brokers list pulsar-cluster