概述¶
一个完整的Pulsar集群由Pulsar broker、必要的 ZooKeeper 和 BookKeeper服务组成,具体的部署方式可分为两种,它们分别是:
-
单机模式(standalone),所有的服务在一台主机上启动,部署简单,适合用于本地开发和测试,也可用于部分生产环境。
-
集群模式(cluster),服务分散在不同的主机上,部署稍微复杂但具有高可用、负载均衡等特性适用于生产环境。
一. 前置条件¶
- Java 8
- Linux 操作系统
二. 下载Pulsar 2.7.0安装包¶
从 Pulsar 官网下载页下载
或
使用 wget 命令下载:
$ wget https://archive.apache.org/dist/pulsar/pulsar-2.7.0/apache-pulsar-2.7.0-bin.tar.gz
下载好压缩文件后,解压缩至 "/data/projects/fate/common" 并使用cd
命令进入文件所在位置:
$ tar -xvzf apache-pulsar-2.7.0-bin.tar.gz -C /data/projects/fate/common
$ cd /data/projects/fate/common/apache-pulsar-2.7.0
三. 启动单机版Pulsar¶
- 编辑"conf/standalone.conf"文件, 修改如下:
# 打开自动删除非活跃topic功能
brokerDeleteInactiveTopicsEnabled=true
# 设置非活跃topic扫描间隔
brokerDeleteInactiveTopicsFrequencySeconds=180
# 设置用于镜像复制的链接数
replicationConnectionsPerBroker=4
# 修改bookkie的frame容量大小位128MB,默认为5MB
nettyMaxFrameSizeBytes=134217728
# 增加pulsar message容量的大小为128MB,默认为5MB
maxMessageSize=134217728
- 启动单机版pulsar
$ bin/pulsar-daemon start standalone -nss
- 停止pulsar
当pulsar不再需要时可用以下命令停止。
$ bin/pulsar-daemon stop standalone
当不需要pulsar产生的数据时可以移出除"apache-pulsar-2.7.0"下的"data"目录。
更多关于单机版Pulsar的配置,请参考Pulsar官方文档Set up a standalone Pulsar locally
四. 启动集群版Pulsar集群¶
对于集群模式的Pulsar服务部署,请参考官方文档Deploying a multi-cluster on bare metal,其中部署配置存储集群部分的步骤可略过。
最后更新:
2022-07-07