千家信息网

Kafka partitions 迁移

发表于:2025-01-23 作者:千家信息网编辑
千家信息网最后更新 2025年01月23日,echo '{"topics":[{"topic": "test1"},{"topic":"test2"}], "version":1}' >ready-move-topics.json/usr/hd
千家信息网最后更新 2025年01月23日Kafka partitions 迁移
echo '{"topics":[{"topic": "test1"},{"topic":"test2"}], "version":1}' >ready-move-topics.json/usr/hdp/current/kafka-broker/bin/kafka-reassign-partitions.sh --zookeeper agent01.ambari.com:2181,agent02.ambari.com:2181,server.ambari.com:2181/kafka --topics-to-move-json-file ready-move-topics.json --broker-list "1001,1002" --generate|sed -ne '/Proposed partition reassignment configuration/,$p'|grep -v "Proposed partition reassignment configuration"将结果保存到 relayout-partitions.json 文件中/usr/hdp/current/kafka-broker/bin/kafka-reassign-partitions.sh --zookeeper agent01.ambari.com:2181,agent02.ambari.com:2181,server.ambari.com:2181/kafka --reassignment-json-file relayout-partitions.json --execute/usr/hdp/current/kafka-broker/bin/kafka-reassign-partitions.sh --zookeeper agent01.ambari.com:2181,agent02.ambari.com:2181,server.ambari.com:2181/kafka --reassignment-json-file relayout-partitions.json --verify
0