pulsar安装

2022-06-07 16:37:18 阅读：283 来源： 互联网

标签：10.181 manager 192.168 2181 pulsar 安装节点

准备环境

三节点
- 192.168.10.181 (pulsar1)
- 192.168.10.182 (pulsar2)
- 192.168.10.183 (pulsar3)
zookeeper版本：apache-zookeeper-3.7.1-bin.tar
- 192.168.10.140 (zookeeper1)
- 192.168.10.141 (zookeeper2)
- 192.168.10.142 (zookeeper3)
jdk: jdk-8u333
pulsar: apache-pulsar-2.10.0-bin.tar.gz
上传安装包到三节点的/opt/pulsar目录
停止/关闭防火墙

配置环境

配置hostname 三台节点配置

# echo "192.168.10.181 pulsar1" >> /etc/hosts
# echo "192.168.10.182 pulsar2" >> /etc/hosts
# echo "192.168.10.183 pulsar3" >> /etc/hosts

# cat /etc/hosts
127.0.0.1   localhost localhost.localdomain localhost4 localhost4.localdomain4
::1         localhost localhost.localdomain localhost6 localhost6.localdomain6
192.168.10.181 pulsar1
192.168.10.182 pulsar2
192.168.10.183 pulsar3

安装

三节点解压

# cd /opt/pulsar
# tar zxvf apache-pulsar-2.10.0-bin.tar.gz
# ln -s ./apache-pulsar-2.10.0 ./puslar

创建目录
```
# mkdir -p /data/pulsar/
```

修改bookkeeper配置文件

所有节点修改其中advertisedAddress的值每个节点不一致

# vim conf/bookkeeper.conf 
……
# 更改为本地ip地址 每个节点不一样  节点2为 192.168.10.182  节点3为192.168.10.183
advertisedAddress=192.168.10.181
# 修改日志目录
journalDirectory=/data/pulsar/data/bookkeeper/journal
# 修改ledger目录
ledgerDirectories=/data/pulsar/data/pulsar/tmp/ledger
# 修改zk配置
zkServers=192.168.10.140:2181,192.168.10.141:2181,192.168.10.142:2181
……

修改broker配置文件

所有节点修改其中advertisedAddress的值每个节点不一致

# vim conf/broker.conf
……
# 修改集群的名称
clusterName=pulsar-cluster
# 配置zookeeper地址
zookeeperServers=192.168.10.140:2181,192.168.10.141:2181,192.168.10.142:2181
# 配置存储的地址 还是zookeeper地址
globalZookeeperServers=192.168.10.140:2181,192.168.10.141:2181,192.168.10.142:21
81
configurationStoreServers=192.168.10.140:2181,192.168.10.141:2181,192.168.10.142:2181
# 更改为本地ip地址 每个节点不一样  节点2为 192.168.10.182  节点3为192.168.10.183
advertisedAddress=192.168.10.181
……

启动zk集群

确保zk集群正常

# cd /opt/zookeeper/zookeeper && bin/zkServer.sh status

初始化集群信息

cluster: 集群名称
zookeeper：zookeeper地址
configuration：配置文件存储地址
web-service-url：web服务地址建议写ip地址不然其他应用没有hosts链接不成功
web-service-url-tls： web服务tls地址建议写ip地址不然其他应用没有hosts链接不成功
broker-service-url：broker地址建议写ip地址不然其他应用没有hosts链接不成功
broker-service-url-tls ：broker的tls地址建议写ip地址不然其他应用没有hosts链接不成功

# cd /opt/pulsar/puslar/bin

# ./pulsar initialize-cluster-metadata \
--cluster pulsar-cluster \
--zookeeper 192.168.10.140:2181,192.168.10.141:2181,192.168.10.142:2181 \
--configuration-store 192.168.10.140:2181,192.168.10.141:2181,192.168.10.142:2181 \
--web-service-url http://192.168.10.181:8080,192.168.10.182:8080,192.168.10.183:8080 \
--web-service-url-tls https://192.168.10.181:8443,192.168.10.182:8443,192.168.10.183:8443 \
--broker-service-url pulsar://192.168.10.181:6650,192.168.10.182:6650,192.168.10.183:6650 \
--broker-service-url-tls pulsar+ssl://192.168.10.181:6651,192.168.10.182:6651,192.168.10.183:6651

初始化bookeeper信息

接着初始化bookkeeper集群: 若出现提示输入Y/N: 请输入Y
```
# cd /opt/pulsar/puslar/bin
# ./bookkeeper shell metaformat
```

启动bookkeeper

注意: 三个节点都需要依次启动

# cd /opt/pulsar/puslar/bin && ./pulsar-daemon start bookie

# 验证是否启动: 可三台都检测 有Bookie sanity test succeeded即城关
# ./bookkeeper shell bookiesanity

启动broker

注意: 三个节点都需要依次启动

# cd /opt/pulsar/puslar/bin && ./pulsar-daemon start broker

# 检测是否启动 可以三台都验证
# ./pulsar-admin brokers list pulsar-cluster
192.168.10.183:8080
192.168.10.182:8080
192.168.10.181:8080

测试

pulsar的topic名称长比如persistent://public/default/test 代表:永久的还是临时的://哪一个租户的/哪一个命名空间的/topic

persistent: 表示永久的还是临时的
public：哪一个租户的
default：哪一个命名空间的

在任意一个节点中启动消费者和者生产者

# 启动一个消费者
# ./pulsar-client consume persistent://public/default/test -s "consumer-test"

# 一直监听消息
# ./pulsar-client consume persistent://public/default/test -s "consumer-test" -n 0

# 启动一个生产者模拟一条数据
# ./pulsar-client produce persistent://public/default/test --messages "test-pulsar"

监控

下载安装pulsar-manager

https://dist.apache.org/repos/dist/release/pulsar/pulsar-manager/pulsar-manager-0.3.0/apache-pulsar-manager-0.3.0-bin.tar.gz

上传到pulsar1节点解压

# cd /opt/pulsar
# tar -zxvf apache-pulsar-manager-0.3.0-bin.tar.gz 

# cd pulsar-manager/
# tar -xvf pulsar-manager.tar 

# 拷贝ui界面到当manager目录
# cd /opt/pulsar/pulsar-manager/pulsar-manager
# cp -r ../dist ./ui

启动manager

# 只能在这个目录启动
# cd /opt/pulsar/pulsar-manager/pulsar-manager

# ./bin/pulsar-manager

配置超级用户密码

# CSRF_TOKEN=$(curl http://192.168.10.181:7750/pulsar-manager/csrf-token)

# curl \
-H "X-XSRF-TOKEN: $CSRF_TOKEN" \
-H "Cookie: XSRF-TOKEN=$CSRF_TOKEN;" \
-H 'Content-Type: application/json' \
-X PUT http://192.168.10.181:7750/pulsar-manager/users/superuser \
-d '{"name": "pulsar", "password": "pulsar", "description": "test", "email": "makj@test.org"}'
{"message":"Add super user success, please login"}

访问

http://192.168.10.181:7750/ui/index.html

添加集群集群地址为

Service URL：http://192.168.10.181:8080,192.168.10.182:8080,192.168.10.183:8080

Bookie URL: http://192.168.10.181:8000,192.168.10.182:8000,192.168.10.183:8000

标签：10.181,manager,192.168,2181,pulsar,安装,节点
来源： https://www.cnblogs.com/makj/p/16352312.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

pulsar安装

准备环境

配置环境

安装

监控