Kafka kafka-reassign-partitions.sh 命令使用

编辑文件：tmp，内容如下：

{"topics":

[{"topic": "__consumer_offsets"},{"topic": "kafka_topic"}],

"version":1

}

生成reassign结果：

sh kafka-reassign-partitions.sh --generate --zookeeper localhost:2181 --broker-list 0,1,2,3,4,5 --topics-to-move-json-file tmp

将生成json结果拷贝到新的文件：tmp1，执行真正reassign操作

sh kafka-reassign-partitions.sh --execute --zookeeper localhost:2181 --broker-list 0,1,2,3,4,5 --reassignment-json-file tmp1

会在zookeeper下生成一个PERSISTENT节点（哪怕controller切换，也不会删除，从而在新controller启动后，继续进行其未完成操作）：/admin/reassign_partitions 里面是tmp1写入的内容，然后controller不断协调各个broker进行操作，完成的部分会从该节点下删除，最终形成tmp1 json中的内容，后将zookeeper上/admin/reassign_partitions节点删除。

Kafka kafka-reassign-partitions.sh 命令使用相关推荐

读书笔记-kafka常用操作命令-kafka-topics.sh
1. 创建topic bin/kafka-topics.sh --zookeeper localhost:2181/kafka --create --topic topic-create --part ...
跟我学Kafka:Kafka消费组运维详解
作为一个Kafka初学者,需要快速成长,承担维护公司Kafka的重任,对Kafka的学习,我按照三步走策略: 阅读Kafka相关书籍从运维实战的角度学习Kafka 阅读源码,体系化,精细化掌握其实现 ...
python远程登录linux命令,Python+requests通过paramiko远程登录Linux执行sh命令
在做自动化测试过程中, 偶尔需要登录Linux服务器执行一些sh命令.Python的paramiko模块, 遵循SSH2协议, 支持以加密和认证的方式远程连接服务器, 可用来连接远程linux主机, ...
服务器脚本执行sql文件命令行,sh命令执行sql脚本
sh命令执行sql脚本内容精选换一换 GAUSS-51400 : "Failed to execute the command: %s."SQLSTATE: 无错误原因: 执行 ...
ubuntu 下通过 sh 命令运行脚本产生如下错误：[: y: unexpected operator
今天同事在打包 deb 时发生了如下错误: [: y: unexpected operator 脚本代码如下: read -p " Make Release Version [y/n]:&q ...
【Linux】一步一步学Linux——sh命令(225)
00. 目录文章目录 00. 目录 01. 命令概述 02. 命令格式 03. 常用选项 04. 参考示例 05. 附录 01. 命令概述 sh命令是shell命令语言解释器,执行命令从标准输入读取 ...
linux里sh命令是做什么的？详解！
linux里sh命令是做什么的?详解! cs_jiao | 浏览 49759 次 2010-08-20 12:05 2010-08-20 12:29 最佳答案 sh或是执行脚本,或是切换到sh这个 ...
Linux Shell 内建命令 : sh命令详解
sh命令是shell命令语言解释器,执行命令从标准输入读取或从一个文件中读取.通过用户输入命令,和内核进行沟通!Bourne Again Shell (即bash)是自由软件基金会(GNU)开发的一个 ...
[Kafka] Kafka基本架构
[Kafka] Kafka基本架构 [Kafka] Kafka基本架构 [Kafka] Kafka基本架构生产者Producer :生产信息: 消费者Consumer :订阅主题.消费信息: 代理B ...

Kafka kafka-reassign-partitions.sh 命令使用

Kafka kafka-reassign-partitions.sh 命令使用相关推荐

最新文章

热门文章