Kafka3.0使用kafka-reassign-partitions.sh扩容副本时zookeeper选项报错

问题原因 #

Kafka 3.0及更高版本中，kafka-reassign-partitions.sh脚本已移除--zookeeper选项。从Kafka 2.8版本开始，官方逐步推进KRaft模式替代ZooKeeper作为元数据存储，相关管理命令的连接参数统一改为使用--bootstrap-server指向Kafka Broker。

修正后的命令 #

将原命令中的--zookeeper localhost:2181替换为--bootstrap-server <你的Kafka Broker地址:端口>，示例如下：

kafka-reassign-partitions.sh --bootstrap-server localhost:9092 --reassignment-json-file reassign.json --execute

验证重分配状态 #

执行完成后，可使用以下命令验证副本重分配是否成功：

kafka-reassign-partitions.sh --bootstrap-server localhost:9092 --reassignment-json-file reassign.json --verify

内容的提问来源于stack exchange，提问作者Abral George