大橙子网站建设,新征程启航

为企业提供网站建设、域名注册、服务器等服务

Kafkapartitions迁移

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

本文题目:Kafkapartitions迁移
文章URL:http://dzwzjz.com/article/jcscps.html
在线咨询
服务热线
服务热线:028-86922220
TOP