pulsar-4：单机部署pulsar单节点集群

在一台低配机器上部署一个单节点集群极其注意事项。

目录：

(1).准备工作

(2).部署zookeeper

(3).初始化集群元数据

(4).部署bookeeper单节点

(5).部署broker单节点

(6).pulsar-cient连接集群

(7).docker部署pulsar-manager

1.部署pulsar-manager

2.增加超级管理员用户

(1).准备工作

yum install -y java

java版本：11

yum 安装java的默认目录是/usr/lib/jvm/java

export JAVA_HOME=/usr/lib/jvm/jre-11-openjdk/

wget https://archive.apache.org/dist/pulsar/pulsar-2.8.0/apache-pulsar-2.8.0-bin.tar.gz

tar -xzvf apache-pulsar-2.8.0-bin.tar.gz

mv apache-pulsar-2.8.0 /app/3rd/

(2).部署zookeeper

cd apache-pulsar-2.8.0

vim conf/zookeeper.conf

增加配置：

server.1=ip:2888:3888

修改zk metric port:因为bookie也用原值8000，在同一台部署bookie会失败。

metricsProvider.httpPort=8001

mkdir -p data/zookeeper

echo 1 > data/zookeeper/myid

bin/pulsar-daemon start zookeeper

(3).初始化集群元数据

bin/pulsar initialize-cluster-metadata --cluster pulsar-cluster --zookeeper ip:2181 --configuration-store ip:2181 --web-service-url http://ip:8080 --web-service-url-tls https://ip:8443 --broker-service-url pulsar://ip:6650 --broker-service-url-tls pulsar ssl://ip:6651

对应的删除元数据命令是：

bin/pulsar delete-cluster-metadata --cluster pulsar-cluster --zookeeper ip:2181

(4).部署bookeeper单节点

vim conf/bookkeeper.conf:

修改

zkServers=ip:2181

关闭autorecovry:

autoRecoveryDaemonEnabled=false

否则包错：BKNotEnoughBookiesException: Not enough non-faulty bookies available

后台启动bookie:

bin/pulsar-daemon start bookie

你可以通过运行BookKeeper shell上的bookiesanity命令验证 bookie 是否正常工作：

$ bin/bookkeeper shell bookiesanity

这个命令会在本地的 bookie 创建一个临时的 BookKeeper ledger，往里面写一些条目，然后读取它，最后删除这个 ledger。

(5).部署broker单节点

Broker 配置中有一些非常重要的参数，这些参数可以确保每个Broker 连接到已部署的 ZooKeeper 集群。需要确认 zookeeperServers 和 configurationStoreServers 配置项的值是正确的。在当前情况下，由于只有一个集群，没有单独用来存储配置的 Zookeeper 集群，那么配置项configurationStoreServers和zookeeperServers 是一样的值。

vim conf/broker.conf

zookeeperServers=ip:2181

configurationStoreServers=ip:2181

你必须配置集群的名字( 初始化集群元数据提供的集群名字必须和这个配置项匹配)：

clusterName=pulsar-cluster

如果你部署的是单节点的 Pulsar 集群，你需要把配置文件conf/broker.conf的副本数量配置为1.

managedLedgerDefaultEnsembleSize=1

managedLedgerDefaultWriteQuorum=1

managedLedgerDefaultAckQuorum=1

启用 Pulsar Function(可选)

If you want to enable Pulsar Functions, you can follow the instructions as below:

将conf/broker.conf文件的配置项functionsWorkerEnabled设置为true，启用函数 worker，

functionsWorkerEnabled=true

修改conf/functions_worker.yml的配置项pulsarFunctionsCluster 为集群的名称，该名称和初始化集群元数据使用的集群名字是同一个。

pulsarFunctionsCluster: pulsar-cluster

后台启动broker:

bin/pulsar-daemon start broker

(6).pulsar-cient连接集群

vim conf/client.conf

如果你没有 DNS 服务器，你能够使用多个域名组成的格式的服务的 URL：

webServiceUrl=http://ip:8080

brokerServiceUrl=pulsar://ip:6650

启动consumer监听：

bin/pulsar-client consume persistent://public/default/test -n 100 -s "consumer-test" -t "Exclusive"

启动producer发送消息：

bin/pulsar-client produce persistent://public/default/test -n 1 -m "Hello Pulsar"

可以在consumer上看到打印：

(7).docker部署pulsar-manager

1.部署pulsar-manager

mkdir -p /root/docker-local/docker-local-pulsar-manager/conf

下载bkvm.conf文件到制定目录：

cp https://github.com/apache/pulsar-manager/blob/master/src/main/resources/bkvm.conf /root/docker-local/docker-local-pulsar-manager/conf

下载application.properties文件到制定目录：

cp https://github.com/apache/pulsar-manager/blob/master/src/main/resources/application.properties /root/docker-local/docker-local-pulsar-manager/conf

修改bkvm.conf：

Enable bookkeeper visual manager(Optional)：

bkvm.enabled=true

# BookKeeper Connection

# Default value zk null://127.0.0.1:2181/ledgers works for Pulsar Standalone

metadataServiceUri=zk null://bookie所在机器的ip:2181/ledgers

修改application.properties：

support peek message, default false：

pulsar.peek.message=true

#开启swagger

swagger.enabled=true

启动pulsar-manager：

docker run -it -d -p 9527:9527 -p 7750:7750 -e SPRING_CONFIGURATION_FILE=/pulsar-manager/pulsar-manager/application.properties -v /root/docker-local/docker-local-pulsar-manager/conf/bkvm.conf:/pulsar-manager/pulsar-manager/bkvm.conf -v /root/docker-local/docker-local-pulsar-manager/conf/application.properties:/pulsar-manager/pulsar-manager/application.properties --name pulsar-manager apachepulsar/pulsar-manager

登陆pulsar-manager：

http:/ip:9527/

2.增加超级管理员用户

增加超级管理员用户和密码：

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

curl -H "X-XSRF-TOKEN:

超级管理员新增参考官方文档：特别注意字符问题：

https://github.com/apache/pulsar-manager#access-pulsar-manager