以下是Kafka集群简便扩容步骤:
准备新节点
server.properties:设置唯一broker.id、监听地址(listeners)、日志目录(log.dirs)、ZooKeeper连接地址(zookeeper.connect)。启动新节点
bin/kafka-server-start.sh config/server.properties启动Broker。ls /brokers/ids验证新节点是否加入集群。可选:分区重分配(均衡负载)
kafka-reassign-partitions.sh工具:
--generate参数指定Topic列表和目标Broker列表。--execute参数应用计划。--verify参数查看状态。简化关键点: