Kafka 1.0 HDP集群执行preferred-replica-election命令报错排查
Kafka 1.0版本preferred-replica-election.sh参数异常排查
Kafka 1.0版本的kafka-preferred-replica-election.sh脚本不支持--topic和--bootstrap-server这两个参数,这是版本兼容性导致的——这两个参数是Kafka 2.0及以上版本才引入的简化参数,1.0版本仍使用旧的参数格式和执行逻辑。
正确执行单个分区优先副本选举的步骤
针对topic_test的0号分区,需要通过JSON文件指定目标分区:
- 创建选举配置文件(比如命名为
election_config.json),内容如下:{ "partitions": [ {"topic": "topic_test", "partition": 0} ] } - 执行脚本,通过
--zookeeper指定ZooKeeper地址,--path-to-json-file指向上述配置文件:kafka-preferred-replica-election.sh --zookeeper <zk集群地址:端口> --path-to-json-file election_config.json
全集群优先副本选举命令
如果需要对所有topic的所有分区执行优先副本选举,直接使用--zookeeper参数即可:
kafka-preferred-replica-election.sh --zookeeper <zk集群地址:端口>
报错原因说明
--bootstrap-server:Kafka 2.0+版本才用该参数替代--zookeeper来连接集群,1.0版本仅支持通过ZooKeeper地址连接。--topic:该简化参数同样是高版本新增,1.0版本必须通过JSON配置文件指定要操作的分区或topic。
内容的提问来源于stack exchange,提问作者Judy
相关产品推荐
相关产品推荐

