基于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 具备良好的高可用机制,依然保持服务的连续性和稳定性。