基于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.pswp.cn/bicheng/88842.shtml
繁体地址,请注明出处:http://hk.pswp.cn/bicheng/88842.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

JAVA JVM垃圾收集

JVM 垃圾收集是 Java 自动内存管理的核心,本文通过围绕 “哪些是垃圾、何时回收、怎么回收、用啥回收器、内存咋分配” 等展开一、判断哪些是垃圾引用计数法:给对象分配引用计数器,有引用时计数加 1,引用失效减 1 ,计数…

UniHttp生命周期钩子与公共参数实战:打造智能天气接口客户端

> 通过灵活的生命周期钩子,我们让HTTP请求从机械操作进化为智能对话 在现代应用开发中,高效处理HTTP请求是核心能力。本文将深入探索UniHttp框架中强大的**HttpApiProcessor生命周期钩子**,并演示如何利用其**公共参数填充机制**优雅地处理第三方接口。我们将以百度天…

C++高级编程,类模版成员函数类外实现

#include <iostream> #include <string>//类模版成员函数类外实现 template<class T1,class T2> class Person {//Person构造函数 public:Person(T1 name,T2 age);// {// this->m_Namename;// this->m_Ageage;// }//Person的成员函数void show…

[Linux入门 ] RAID存储技术概述

一.数据存储架构 1️⃣存储系统 2️⃣主机系统 3️⃣互连部件 4️⃣存储设备与磁盘阵列 二.数据存储技术 1️⃣数据冗余技术 2️⃣RAID 0 3️⃣RAID 1 4️⃣RAID 2 5️⃣RAID 3 6️⃣RAID 4 三.基于硬件的RAID磁盘阵列 1️⃣阵列卡(RAID控制器) 2️⃣阵列卡种类 …

AI绘画生成章邯全身像提示词

融合了历史元素和视觉表现力&#xff0c;力求生成符合秦末名将章邯身份的全身像。 核心提示词结构&#xff1a; [主体描述]&#xff0c;[服装/盔甲细节]&#xff0c;[姿态/神情]&#xff0c;[武器]&#xff0c;[背景/氛围]&#xff0c;[风格/质量]&#xff0c;[参数] 选项一&…

iOS高级开发工程师面试——关于优化

iOS高级开发工程师面试——关于优化 一、TableView 有什么好的性能优化方案?二、界面卡顿和检测你都是怎么处理?三、谈谈你对离屏渲染的理解?四、如何降低APP包的大小?五、日常如何检查内存泄露?六、APP启动时间应从哪些方面优化?一、TableView 有什么好的性能优化方案?…

线性基学习笔记

我们称一个线性空间 V V V 的一个极大线性无关集为这个线性空间的线性基,简称基。 异或线性基 在异或空间下,我们定义如下内容。 异或和 设 S S

ESP-Timer入门(基于ESP-IDF-5.4)

主要参考资料&#xff1a; ESP 定时器&#xff08;高分辨率定时器&#xff09;: https://docs.espressif.com/projects/esp-idf/zh_CN/stable/esp32s3/api-reference/system/esp_timer.html 目录ESP-Timer与FreeRTOS TimerAPI 使用1.创建定时器2.启动定时器3.管理定时器4.时间管…

014_批处理与大规模任务

批处理与大规模任务 目录 批处理概述核心优势技术规格API使用管理和监控应用场景最佳实践 批处理概述 什么是批处理 批处理&#xff08;Batch Processing&#xff09;是一种异步处理大量Claude API请求的方法&#xff0c;允许您一次性提交多个消息请求&#xff0c;系统将在…

Python淘宝拍立淘按图搜索API接口,json数据示例参考

淘宝拍立淘按图搜索API接口示例淘宝的拍立淘(图片搜索)功能通常是通过淘宝开放平台提供的API实现的。以下是一个模拟的JSON数据示例和接口调用参考&#xff1a;模拟API请求示例import requestsimport base64# 示例图片路径image_path "example.jpg"# 读取图片并编码…

静默的田野革命—人工智能重构农业生态的技术风暴与文明悖论

一、饥饿困局的数字突围当全球粮食损失率高达30%&#xff08;约13亿吨&#xff09;与8亿人营养不良并存&#xff0c;当农药滥用导致传粉昆虫种群崩溃与地下水资源枯竭&#xff0c;传统农业的生态死结日益收紧。这场危机的核心是生物复杂性对工业化农业的报复&#xff1a;小麦基…

【大模型推理论文阅读】 Thinking Tokens are Information Peaks in LLM Reasoning

Demystifying Reasoning Dynamics with Mutual Information&#xff1a;Thinking Tokens are Information Peaks in LLM Reasoning 摘要 大语言推理模型&#xff08;LRM&#xff09;在复杂问题解决方面展现出了令人瞩目的能力&#xff0c;但其内部推理机制仍未得到充分理解。…

【TCP/IP】14. 远程登录协议

14. 远程登录协议14. 远程登录协议14.1 基本概念14.2 Telnet 命令14.3 Telnet 选项及协商14.4 Telnet 子选项协商14.5 Telnet 操作模式本章要点14. 远程登录协议 14.1 基本概念 Telnet 协议是 TCP/IP 协议族的重要成员&#xff0c;核心功能是实现本地计算机对远程主机的终端仿…

Flink1.20.1集成Paimon遇到的问题

flinkcdc mysql 到paimon 1&#xff1a;Caused by: java.lang.ClassNotFoundException: org.apache.kafka.connect.data.Schema 可以参考这个文章 明确指出了flink-connector-mysql-cdc-3.4.0.jar存在这个包&#xff0c;但是flink-sql-connector-mysql-cdc-3.4.0.jar中没有这个…

C++高频知识点(十)

文章目录46. 智能指针是什么&#xff1f;怎么使用?1. std::unique_ptr2. std::shared_ptr3. std::weak_ptr47. 什么是野指针&#xff1f;1. 使用已释放的指针2. 未初始化的指针3. 指针超出作用域如何避免野指针1. 立即将指针置空2. 初始化指针3. 使用智能指针4. 避免返回局部变…

c#中Random类、DateTime类、String类

C# 中 Random 类分析Random 类用于生成伪随机数&#xff0c;位于 System 命名空间。它的核心机制是基于一个种子值 (seed)&#xff0c;通过算法生成看似随机的数列。相同种子会生成相同的随机数序列&#xff0c;这在需要可重现的随机场景中很有用。核心特点种子与随机性默认构造…

Vscode 下载远程服务器失败解决方法

今天在使用 vscode 连接远程主机时&#xff0c;突然再次遇到这个问题&#xff0c;按照以往的经验&#xff0c;直接按照这个博主的文章其实就能解决&#xff0c;但是不知道为什么&#xff0c;今天这个方案失效了&#xff0c;然后卸载安装服务器和本机的vscode什么的也都试过了&a…

【算法】贪心算法:柠檬水找零C++

文章目录前言题目解析算法原理代码示例策略证明前言 题目的链接&#xff0c;大家可以先试着去做一下再来看一下思路。 860. 柠檬水找零 - 力扣&#xff08;LeetCode&#xff09; 题目解析 首先我们要认真去拿到题目中的关键有用信息。 认真的去阅读题目给的示例&#xff0c;然…

27.【.NET8 实战--孢子记账--从单体到微服务--转向微服务】--单体转微服务--币种服务(一)

从本篇文章开始&#xff0c;我们将用两篇内容详细介绍币种服务的实现。币种服务本身结构较为简单&#xff0c;核心功能包括内置币种的初始化、币种汇率的同步以及汇率的查询。在本篇中&#xff0c;我们将重点讲解如何实现内置币种的初始化功能&#xff0c;为后续的服务打下基础…

(2)从零开发 Chrome 插件:实现 API 登录与本地存储功能

从零开发 Chrome 插件&#xff1a;实现 API 登录与本地存储功能 Chrome 插件作为浏览器功能的重要扩展&#xff0c;能极大提升用户的工作效率。本文将以一个「登录功能插件」为例&#xff0c;带你从零构建一个可调用 API 验证身份、并将用户信息存储在本地的 Chrome 插件。 基…