跳转至

概述

一个完整的Pulsar集群由Pulsar broker、必要的 ZooKeeper 和 BookKeeper服务组成,具体的部署方式可分为两种,它们分别是:

  1. 单机模式(standalone),所有的服务在一台主机上启动,部署简单,适合用于本地开发和测试,也可用于部分生产环境。

  2. 集群模式(cluster),服务分散在不同的主机上,部署稍微复杂但具有高可用、负载均衡等特性适用于生产环境。

一. 前置条件

  1. Java 8
  2. 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

  1. 编辑"conf/standalone.conf"文件, 修改如下:

# 打开自动删除非活跃topic功能
brokerDeleteInactiveTopicsEnabled=true

# 设置非活跃topic扫描间隔
brokerDeleteInactiveTopicsFrequencySeconds=36000

# 设置用于镜像复制的链接数
replicationConnectionsPerBroker=4

# 修改bookkie的frame容量大小位128MB,默认为5MB
nettyMaxFrameSizeBytes=134217728

# 增加pulsar message容量的大小为128MB,默认为5MB
maxMessageSize=134217728


# Default per-topic backlog quota limit
backlogQuotaDefaultLimitGB=-1
更多关于配置字段的描述可以参考配置文件的注释。

  1. 启动单机版pulsar

$ bin/pulsar-daemon start standalone -nss
运行日志在pulsar软件部署目录下层的logs目录下。

  1. 停止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,其中部署配置存储集群部分的步骤可略过。


最后更新: 2023-06-14