Kafka集群扩容主要通过添加新Broker节点实现,步骤如下:
准备工作
添加新Broker节点
server.properties,设置唯一broker.id、监听地址(listeners)、日志目录(log.dirs)及ZooKeeper连接信息。kafka-server-start.sh启动Broker,确保节点成功加入集群。更新集群配置(可选)
分区重分配(可选)
kafka-reassign-partitions.sh工具生成并执行分区迁移计划,将部分分区迁移到新节点,实现负载均衡。验证与监控
kafka-topics.sh查看Topic分布,确认新节点已承担流量。注意事项:
参考来源: