Linux下部署Apache Pulsar消息队列

夏瑶同学_6964

夏瑶同学_6964

2026-06-16

917人浏览

原创

单机模式oom需调低jvm堆内存并禁用内置zookeeper;集群元数据初始化失败主因是zk地址不一致或残留节点;broker注册失败多因advertisedaddress配置错误;client连接拒绝须检查防火墙、安全组及docker/k8s端口映射。

linux下部署apache pulsar消息队列

单机模式启动失败:pulsar standalone 报 java.lang.OutOfMemoryError

小内存服务器(比如 2G RAM)跑 pulsar standalone 极大概率直接 OOM,因为默认 JVM 参数对 Broker + BookKeeper + ZooKeeper 三合一进程过于激进。

解决办法不是换机器,而是调低堆内存并禁用非必要组件:

  • 编辑 conf/standalone.conf,把 brokerHeapSizeMB 改成 512,bookieHeapSizeMB 改成 384
  • 在 bin/pulsar 启动脚本顶部追加:export PULSAR_MEM="-Xms256m -Xmx512m"
  • 如果只是测试生产/消费逻辑,可跳过 ZooKeeper 内嵌——改用外部 ZooKeeper(哪怕单节点),再执行 bin/pulsar standalone --no-zk-run

注意:--no-zk-run 不代表不用 ZooKeeper,它只是不拉起内置实例;你必须提前运行好 ZooKeeper 并在 conf/standalone.conf 中配好 zookeeperServers。

集群部署时 pulsar initialize-cluster-metadata 命令反复失败

这个命令失败通常不是权限或网络问题,而是元数据已存在却未清理干净,或者 --configuration-store 和 --zookeeper 指向了不同 ZK 实例。

关键检查点:

  • 确认 --zookeeper 和 --configuration-store 的地址完全一致(端口、IP、域名都不能差一点)
  • 用 echo stat | nc zk-host 2181 验证 ZK 是否可连且处于 leader 状态
  • 如果之前执行过但失败,先手动清空 ZK 路径:./bin/pulsar-admin namespaces list 若报错“namespace not found”,大概率是 /ledgers 或 /config 节点残留;此时需用 zkCli.sh 连上去删掉 /ledgers、/config、/pulsar(谨慎操作)

别依赖“重试”——Pulsar 对元数据一致性极其严格,一次写入失败后残留半成品比没写更麻烦。

Linux installer
Linux installer

先解析安全源,运行本地CLI安装、启动、卸载Linux桌面应用。用户请求时使用。

下载

Broker 启动后无法注册到 ZooKeeper,log 里反复出现 Failed to register broker

这问题表面是网络不通,实际常因 advertisedAddress 配置错误。Broker 会把自己这个地址告诉 ZooKeeper,消费者和 Producer 也靠它来连接;如果填的是 localhost 或内网 IP,外部客户端必然连不上。

正确做法:

  • 在 conf/broker.conf 中,advertisedAddress 必须填**客户端能直连的 IP 或域名**(例如公网 IP、K8s Service 名、宿主机可解析的 hostname)
  • bindAddresses 可设为 0.0.0.0,表示监听所有接口;但 advertisedAddress 绝不能是 0.0.0.0
  • 验证方式:启动后查 ZK 中的 broker 注册路径:ls /brokers,然后 get /brokers/xxx,看返回 JSON 里的 address 字段是否是你期望的地址

很多团队卡在这一步数小时,就因为 advertisedAddress 沿用了默认值或抄了文档里的 localhost 示例。

Java Client 连不上 pulsar://host:6650,抛 Connection refused

Broker 默认只监听 0.0.0.0:6650,但 Linux 防火墙或云厂商安全组往往默认拦截该端口。这不是 Pulsar 配置问题,而是基础设施层漏掉了。

快速定位步骤:

  • 在 Broker 服务器上执行:ss -tlnp | grep :6650,确认进程确实在监听
  • 在同一台机器上执行:telnet localhost 6650,通则说明服务正常,问题出在网络层
  • 从客户端机器执行:telnet broker-host 6650;不通就立刻检查防火墙:sudo firewall-cmd --list-ports(CentOS)或 sudo ufw status(Ubuntu),开放 6650
  • 云服务器务必检查安全组规则——6650 TCP 入方向必须放行,且源 IP 设置合理(不要只写 0.0.0.0/0)

最容易被忽略的是:Docker 部署时没加 -p 6650:6650,或 Kubernetes Service 没暴露该端口。连不上时,先别翻 Pulsar 日志,先做端口连通性验证。

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

linux apache

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
磁盘配额是什么
磁盘配额是什么

磁盘配额是计算机中指定磁盘的储存限制,就是管理员可以为用户所能使用的磁盘空间进行配额限制,每一用户只能使用最大配额范围内的磁盘空间。php中文网为大家提供各种磁盘配额相关的内容,教程,供大家免费下载安装。

2023.06.21

3990

4

如何安装LINUX
如何安装LINUX

本站专题提供如何安装LINUX的相关教程文章,还有相关的下载、课程,大家可以免费体验。

2023.06.29

3413

10

linux find
linux find

find是linux命令,它将档案系统内符合 expression 的档案列出来。可以指要档案的名称、类别、时间、大小、权限等不同资讯的组合,只有完全相符的才会被列出来。find根据下列规则判断 path 和 expression,在命令列上第一个 - ( ) , ! 之前的部分为 path,之后的是 expression。还有指DOS 命令 find,Excel 函数 find等。本站专题提供linux find相关教程文章,还有相关

2023.06.30

2573

5

linux修改文件名
linux修改文件名

本专题为大家提供linux修改文件名相关的文章,这些文章可以帮助用户快速轻松地完成文件名的修改工作,大家可以免费体验。

2023.07.05

6250

7

linux系统安装教程
linux系统安装教程

linux系统是一种可以免费使用,自由传播,多用户、多任务、多线程、多CPU的操作系统。本专题提供linux系统安装教程相关的文章,大家可以免费体验。

2023.07.06

5902

7

linux查看文件夹大小
linux查看文件夹大小

Linux是一种自由和开放源码的类Unix操作系统,存在着许多不同的Linux版本,但它们都使用了Linux内核。Linux可安装在各种计算机硬件设备中,比如手机、平板电脑、路由器、视频游戏控制台、台式计算机、大型机和超级计算机。linux怎么查看文件夹大小呢?php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.07.20

3453

8

linux查看ip命令
linux查看ip命令

本专题为大家提供linux查看ip命令相关文章内容,感兴趣的朋友可以免费下载体验试试。

2023.07.20

2945

4

linux查看cpu使用率
linux查看cpu使用率

在linux的系统维护中,可能需要经常查看cpu使用率,分析系统整体的运行情况。本专题为大家带来了linux查看cpu使用率的相关文章,感兴趣的朋友千万不要错过了。

2023.07.25

3179

6

linux查找文件命令
linux查找文件命令

Linux是一种自由和开放源码的类Unix操作系统,存在着许多不同的Linux版本,但它们都使用了Linux内核。Linux可安装在各种计算机硬件设备中,比如手机、平板电脑、路由器、视频游戏控制台、台式计算机、大型机和超级计算机。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.07.31

297

3

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Buffalo框架快速入门指南
Buffalo框架快速入门指南

共0课时 | 0人学习

Valgrind支持平台说明
Valgrind支持平台说明

共0课时 | 0人学习