手动调整broker扩容后的旧topic分区
在broker扩容了两台机器之后,想让旧topic:quickstart76-events的分区也能铺满broker
1、创建一个topics-to-move.json json文件
$ vim topics-to-move.json json
{"topics": [{"topic":"quickstart76-events"}],"version":1
}
2、执行命令:
$ /data/kafka_2.13-3.0.0/bin/kafka-reassign-partitions.sh --bootstrap-server 192.168.233.132:9092 --topics-to-move-json-file ./topics-to-move.json --broker-list "0,1,2,3,4,5" --generate
得到输出:
Current partition replica assignment
{"version":1,"partitions":[{"topic":"quickstart76-events","partition":0,"replicas":[3,2],"log_dirs":["any","any"]},{"topic":"quickstart76-events","partition":1,"replicas":[1,3],"log_dirs":["any","any"]},{"topic":"quickstart76-events","partition":2,"replicas":[0,1],"log_dirs":["any","any"]},{"topic":"quickstart76-events","partition":3,"replicas":[2,0],"log_dirs":["any","any"]},{"topic":"quickstart76-events","partition":4,"replicas":[3,1],"log_dirs":["any","any"]},{"topic":"quickstart76-events","partition":5,"replicas":[1,0],"log_dirs":["any","any"]}]}Proposed partition reassignment configuration
{"version":1,"partitions":[{"topic":"quickstart76-events","partition":0,"replicas":[4,5],"log_dirs":["any","any"]},{"topic":"quickstart76-events","partition":1,"replicas":[5,0],"log_dirs":["any","any"]},{"topic":"quickstart76-events","partition":2,"replicas":[0,1],"log_dirs":["any","any"]},{"topic":"quickstart76-events","partition":3,"replicas":[1,2],"log_dirs":["any","any"]},{"topic":"quickstart76-events","partition":4,"replicas":[2,3],"log_dirs":["any","any"]},{"topic":"quickstart76-events","partition":5,"replicas":[3,4],"log_dirs":["any","any"]}]}
将Proposed partition reassignment configuration的json保存到expand-cluster-reassignment.json文件中
$vim expand-cluster-reassignment.json
{"version":1,"partitions":[{"topic":"quickstart76-events","partition":0,"replicas":[4,5],"log_dirs":["any","any"]},{"topic":"quickstart76-events","partition":1,"replicas":[5,0],"log_dirs":["any","any"]},{"topic":"quickstart76-events","partition":2,"replicas":[0,1],"log_dirs":["any","any"]},{"topic":"quickstart76-events","partition":3,"replicas":[1,2],"log_dirs":["any","any"]},{"topic":"quickstart76-events","partition":4,"replicas":[2,3],"log_dirs":["any","any"]},{"topic":"quickstart76-events","partition":5,"replicas":[3,4],"log_dirs":["any","any"]}]}
执行命令:
/data/kafka_2.13-3.0.0/bin/kafka-reassign-partitions.sh --bootstrap-server 192.168.233.132:9092 --reassignment-json-file ./expand-cluster-reassignment.json --execute
执行完之后查看topic分区:
$ /data/kafka_2.13-3.0.0/bin/kafka-topics.sh --bootstrap-server 192.168.233.132:9092 --topic quickstart76-events --describe
Topic: quickstart76-events TopicId: RTYJMgt-SbSPERLyUkAI6Q PartitionCount: 6 ReplicationFactor: 2 Configs: segment.bytes=1073741824Topic: quickstart76-events Partition: 0 Leader: 4 Replicas: 4,5 Isr: 4,5Topic: quickstart76-events Partition: 1 Leader: 5 Replicas: 5,0 Isr: 5,0Topic: quickstart76-events Partition: 2 Leader: 0 Replicas: 0,1 Isr: 0,1Topic: quickstart76-events Partition: 3 Leader: 1 Replicas: 1,2 Isr: 1,2Topic: quickstart76-events Partition: 4 Leader: 2 Replicas: 2,3 Isr: 2,3Topic: quickstart76-events Partition: 5 Leader: 3 Replicas: 3,4 Isr: 3,4
看到分区已经铺满broker了。
相关文章:
手动调整broker扩容后的旧topic分区
在broker扩容了两台机器之后,想让旧topic:quickstart76-events的分区也能铺满broker 1、创建一个topics-to-move.json json文件 $ vim topics-to-move.json json {"topics": [{"topic":"quickstart76-events"}],"v…...
【LeetCode-简单】剑指 Offer 25. 合并两个排序的链表(详解)
题目 入两个递增排序的链表,合并这两个链表并使新链表中的节点仍然是递增排序的。 示例1: 输入:1->2->4, 1->3->4 输出:1->1->2->3->4->4 本题与主站 21 题相同:力扣 题目地址&#x…...
Java版工程行业管理系统源码-专业的工程管理软件-em提供一站式服务
Java版工程项目管理系统 Spring CloudSpring BootMybatisVueElementUI前后端分离 功能清单如下: 首页 工作台:待办工作、消息通知、预警信息,点击可进入相应的列表 项目进度图表:选择(总体或单个)项目…...
【Spring】简化事件的使用,Spring提供了2种使用方式
Spring中事件可以配置顺序,利用线程池还可以做异步线程通知。怎么样使用事件?Spring简化事件的使用,Spring提供了2种使用方式:面向接口和面向EventListener注解。 1,面相接口的方式 案例 发布事件 需要先继承ApplicationEventP…...
探究Spring事务:了解失效场景及应对策略
在现代软件开发中,数据的一致性和完整性是至关重要的。为了保证这些特性,Spring框架提供了强大的事务管理机制,让开发者能够更加自信地处理数据库操作。然而,事务并非银弹,存在一些失效的情景,本文将带您深…...
Maven Manifold 条件编译
Maven 配置 通过 Maven 的不同 profile 实现不同环境传递不同符号。另外 lombok 可以 manifold 一同使用,见下方配置。 <properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.targ…...
4.数组与基本数学函数
一、数组 1.概念 数组是存放相同类型对象的容器,数组中存放的对象没有名字,而是要通过其所在的位置访问。数组中的每一个元素都相当于一个普通的变量,可以和普通变量一样进行赋值操作。 数组可以帮助我们批量地处理相同数据类型的相关数据…...
python与深度学习(十六):CNN和宝可梦模型二
目录 1. 说明2. 宝可梦模型的CNN模型测试2.1 导入相关库2.2 加载模型2.3 设置保存图片的路径2.4 加载图片2.5 数据处理和归一化2.6 对图片进行预测2.7 显示图片 3. 完整代码和显示结果4. 多张图片进行测试的完整代码以及结果 1. 说明 本篇文章是对上篇文章宝可梦模型训练的模型…...
PTA 1030 Travel Plan
个人学习记录,代码难免不尽人意。 A traveler’s map gives the distances between cities along the highways, together with the cost of each highway. Now you are supposed to write a program to help a traveler to decide the shortest path between his/h…...
MFC、Qt、WPF?该用哪个?
MFC、Qt和WPF都是流行的框架和工具,用于开发图形用户界面(GUI)应用程序。选择哪个框架取决于你的具体需求和偏好。MFC(Microsoft Foundation Class)是微软提供的框架,使用C编写,主要用于Windows…...
使用logback记录日志
1. Pom引用依赖 <dependency> <groupId>ch.qos.logback</groupId> <artifactId>logback-classic</artifactId> <version>1.2.11</version> </dependency> 2. logback.xml <?xml version"1.0" encoding"U…...
企业工程项目管理系统源码(三控:进度组织、质量安全、预算资金成本、二平台:招采、设计管理) em
工程项目管理软件(工程项目管理系统)对建设工程项目管理组织建设、项目策划决策、规划设计、施工建设到竣工交付、总结评估、运维运营,全过程、全方位的对项目进行综合管理 工程项目各模块及其功能点清单 一、系统管理 1、数据字典&#…...
【安装】XMind2022XMind2020安装教程(资源)
Xmind是一个制作思维导图很便利的软件。 1.资源链接 Xmind2022: 链接:https://pan.baidu.com/s/1j4DFedxxX2YJ3HBy1-MpHw?pwdxmin 提取码:xmin Xmind2020: 链接:https://pan.baidu.com/s/1wNqMApuy0yoBF2CvpBDpDA?pwdxmin 提取码&#x…...
Windows下QT Creator安装MinGW 32bit编译器
前言 注:本作者是基于FFmpeg开发需要,故在Windows下QT Creator中安装MinGW 32bit编译器!其它型号编译器参照此文章基本可以实现! 一、下载需要的编译器 1、下载链接 链接: 链接:https://pan.baidu.com/…...
Emacs之解决键值绑定冲突问题(一百二十三)
简介: CSDN博客专家,专注Android/Linux系统,分享多mic语音方案、音视频、编解码等技术,与大家一起成长! 优质专栏:Audio工程师进阶系列【原创干货持续更新中……】🚀 人生格言: 人生…...
瞄准产业应用,大模型加持的深兰科技AI虚拟数字人落地业务场景
伴随ChatGPT的问世,在技术与商业运作上都日渐发展成熟的AI数字人产业正持续升温。 目前的AI数字人不仅拥有超高“颜值”,同时还拥有更为丰富的、细腻的表情和动作。更有甚者,AI数字人已经具备自定义构建知识图谱、自主对话、不断学习成长的能…...
【网络基础进阶之路】基于MGRE多点协议的实战详解
PS:本要求基于华为的eNSP模拟软件进行 具体要求: 完成步骤: 1、根据上述要求,对各路由器进行地址安排,如下图。 2、进入各路由器,对每个端口进行地址设置。 R1路由器设置: ISP路由器设置&…...
Spark、RDD、Hive 、Hadoop-Hive 和传统关系型数据库区别
Hive Hadoop Hive 和传统关系型数据库区别 Spark 概念 基于内存的分布式计算框架 只负责算 不负责存 spark 在离线计算 功能上 类似于mapreduce的作用 MapReduce的缺点 运行速度慢 (没有充分利用内存)接口比较简单,仅支持Map Reduce功能…...
[运维]python 启用http 文件服务
要在Python中启用HTTP文件服务,您可以使用内置的http.server模块(在Python 3中)或SimpleHTTPServer模块(在Python 2中)。 在Python 3中: python -m http.server在Python 2中: python -m Simp…...
electron-builder 打包 exe 异常错误集锦
项目技术 vue-electron vue-router vuex vuex-electron element-ui echarts mysql 打包异常 Error: Unresolved node modules: vue Error: Unresolved node modules: vue at D:\Code\Demo\Vue\Voice\App\node_modules\_app-builder-lib20.44.4app-builder-lib\src\…...
使用Spring AI Alibaba构建智能体Agent妒
背景 在软件开发的漫长旅途中,"构建"这个词往往让人又爱又恨。爱的是,一键点击,代码变成产品,那是程序员最迷人的时刻;恨的是,维护那一堆乱糟糟的构建脚本,简直是噩梦。 在很多项目中…...
Phi-4-mini-reasoning教育应用效果:学生答题路径模拟与错误归因分析
Phi-4-mini-reasoning教育应用效果:学生答题路径模拟与错误归因分析 1. 模型简介与教育应用价值 Phi-4-mini-reasoning是一个基于合成数据构建的轻量级开源模型,专注于高质量、密集推理的数据处理能力。作为Phi-4模型家族的一员,它特别适合…...
终极指南:3分钟学会用Ofd2Pdf免费实现OFD到PDF无损转换
终极指南:3分钟学会用Ofd2Pdf免费实现OFD到PDF无损转换 【免费下载链接】Ofd2Pdf Convert OFD files to PDF files. 项目地址: https://gitcode.com/gh_mirrors/ofd/Ofd2Pdf Ofd2Pdf是一款专为中国用户设计的开源工具,能够快速、无损地将OFD格式电…...
STIX Two字体:学术排版的终极解决方案
STIX Two字体:学术排版的终极解决方案 【免费下载链接】stixfonts OpenType Unicode fonts for Scientific, Technical, and Mathematical texts 项目地址: https://gitcode.com/gh_mirrors/st/stixfonts 你是否曾经在撰写学术论文时,为数学符号显…...
3分钟上手:跨平台资源下载神器res-downloader全攻略
3分钟上手:跨平台资源下载神器res-downloader全攻略 【免费下载链接】res-downloader 视频号、小程序、抖音、快手、小红书、直播流、m3u8、酷狗、QQ音乐等常见网络资源下载! 项目地址: https://gitcode.com/GitHub_Trending/re/res-downloader 你是否经常遇…...
文墨共鸣:如何用AI理解文字“意思”而不仅仅是“文字”?
文墨共鸣:如何用AI理解文字“意思”而不仅仅是“文字”? 你有没有遇到过这样的情况?两段文字,用词完全不同,但说的却是同一个意思。或者反过来,字面看起来差不多,但想表达的核心观点天差地别。…...
IAR 9.1 版本创建 STM32F1 工程全解析(V3.6.0标准外设库)
一:前言 之前一直用的KEIL MDK 编译ST工程,最近开始学习用IAR搭建工程:先是不知道官网下载的V3.6.0标准外设库,里面的文件该怎么挑、怎么放;再是IAR 9.1版本和网上低版本教程不兼容,一编译就报Pe147错误&a…...
Golang怎么实现SSE服务端推送事件_Golang如何用Server-Sent Events实时推送数据【教程】
Go 的 http.ResponseWriter 能多次写入,但需禁用缓冲、手动刷新并防止中间件断连;SSE 需设正确 header、定时心跳、严格格式输出、绕过干扰中间件,并配置反向代理。Go 的 http.ResponseWriter 为什么不能直接写多次?因为 SSE 要求…...
Phi-4-mini-reasoning辅助软件测试:智能生成测试用例与缺陷推理
Phi-4-mini-reasoning辅助软件测试:智能生成测试用例与缺陷推理 1. 引言:当AI遇见软件测试 "昨天又加班到凌晨,就为了赶测试用例..."这是测试工程师小王的日常吐槽。在软件测试领域,编写全面的测试用例和发现潜在缺陷…...
LangChain重构多Skill Agent系统:智能工具集成实战
LangChain*重构的完整多Skill Agent系统 目录 LangChain*重构的完整多Skill Agent系统 一、LangChain 版本优势 二、完整可运行代码 三、各部分作用解释 1. 工具定义(`@tool` 装饰器) 2. 提示词模板(`ChatPromptTemplate`) 3. Agent 创建与执行器 4. 工具内部调用 LLM(`s…...
