当前位置: 首页 > web >正文

基于k8s环境下pulsar高可用测试和扩缩容(上)

#作者:任少近

文章目录

  • Pulsar高可用测试
    • 1. 测试目的
    • 2.当前集群环境说明
    • 3. 模拟故障场景
    • 4.功能验证
    • 5.结论

Pulsar高可用测试

1. 测试目的

本次测试旨在验证 Apache Pulsar 在某个 Broker 节点宕机(down)的情况下,是否仍能正常提供服务,确保集群具备高可用能力。通过模拟节点故障,观察并验证 Pulsar 集群在异常情况下的自动恢复和持续服务能力。

2.当前集群环境说明

当前 Pulsar 集群中部署了多个 Broker 节点,组成一个完整的分布式消息队列系统。具体节点信息如下:
Broker 节点数:3个(node1、node2、node3)
ZooKeeper 集群:3节点
BookKeeper 集群:3节点
使用的 Pulsar 版本:2.x.x(根据实际情况填写)

当前的pulsar节点数
在这里插入图片描述

3. 模拟故障场景

为了验证高可用性,我们选择将其中一个 Broker 节点 node1 停止服务,模拟节点宕机的异常场景。
操作步骤如下:
停掉bookie-0
在这里插入图片描述

4.功能验证

使用 Pulsar 自带的 pulsar-admin 工具对命名空间和主题进行增删查改等基本操作,以验证集群是否仍然可正常运行。
进行增删查改,验证高可用。

创建命名空间:执行如下命令创建一个新的命名空间 public/test2:
./pulsar-admin namespaces create public/test2
在这里插入图片描述
创建主题:在该命名空间下创建一个名为 topic2 的主题:
在这里插入图片描述
查询主题,执行命令确认主题是否成功创建:
在这里插入图片描述
删除主题,验证删除功能是否正常:
在这里插入图片描述
重复以上操作
反复执行上述操作,确保在节点宕机期间,所有管理接口均能正常使用,无明显异常或超时。

5.结论

通过一系列对命名空间和主题的管理操作,我们验证了在 bookie-0节点宕机的情况下,Pulsar 集群仍能够正常响应请求,完成主题的创建、查询与删除等操作,表明 Pulsar 具备良好的高可用机制,依然保持服务的连续性和稳定性。

http://www.xdnf.cn/news/15240.html

相关文章:

  • Flask 入门到实战(3):用 SQLAlchemy 优雅操作数据库
  • Linux 进程管理核心机制
  • 【mac】快捷键使用指南
  • 【AI大模型】RAG系统组件:向量数据库(ChromaDB)
  • 飞算 JavaAI 体验:重塑 Java 开发的智能新范式
  • LeetCode--43.字符串相乘
  • JVM故障处理与类加载全解析
  • ✨ FastMCP 实战进阶:构建可远程访问的 MCP 工具服务与客户端(Python 深度解析)
  • Elasticsearch混合搜索深度解析(上):问题发现与源码探索
  • 【flutter】flutter网易云信令 + im + 声网rtm从0实现通话视频文字聊天的踩坑
  • 影石(insta360)GO3拇指相机格式化后的恢复方法
  • OpenCV 与深度学习:从图像分类到目标检测技术
  • 如何安装和配置Autoptimize插件以提高WordPress网站访问速度
  • 飞算JavaAI:重塑Java开发的“人机协同“新模式
  • 免费应用分发平台的安全漏洞和防护机制是什么?
  • Jenkins 自动触发执行的配置
  • 飞算JavaAI:重构Java开发的“人机协同”新范式
  • JavaScript VMP (Virtual Machine Protection) 分析与调试
  • 创建显示心电图的组件
  • 前端学习4:小白入门注册表单的制作(包括详细思考CSS、JS实现过程)
  • uniapp语音播报天气预报微信小程序
  • 格密码--数学基础--02基变换、幺模矩阵与 Hermite 标准形
  • 从UI设计到数字孪生实战应用:构建智慧金融的风险评估与预警平台
  • 使用 SSH 连接 GitHub
  • 飞算 JavaAI 深度体验:开启 Java 开发智能化新纪元
  • 速学 RocketMQ
  • 基于定制开发开源AI智能名片与S2B2C商城小程序的旅游日志创新应用研究
  • FPGA实现SDI转LVDS视频发送,基于GTX+OSERDES2原语架构,提供2套工程源码和技术支持
  • Maui劝退:用windows直接真机调试iOS,无须和Mac配对
  • leetcode:518. 零钱兑换 II[完全背包]