Kafka在Linux上的集群扩容策略主要包括以下方面:
新增Broker节点
server.properties文件,设置唯一broker.id、监听地址、ZooKeeper连接等参数。分区与副本调整
kafka-topics.sh工具修改Topic的分区数,提升并行处理能力(注意:此操作不可逆,可能导致数据丢失)。kafka-reassign-partitions.sh脚本手动或自动将分区副本迁移到新节点,均衡负载并提高容错性。配置优化
num.network.threads)、I/O线程数(num.io.threads)等,适配新节点资源。log.dirs指向多个磁盘目录,利用磁盘并行写入提升吞吐量。负载均衡与验证
关键注意事项:
参考来源: