Kafka 分区重分配源码分析

上一篇跟大家描述了 Kafka 集群扩容的方案与过程,这次就跟大家详细描述 Kafka 分区重分配的实现细节。 Kafka 为用户提供了分区重分配的执行脚本 kafka-reassign-partitions.sh,脚本内容如下: ReassignPartitionsCommand 类为我们提供了分区重分配的功能,主要有如下方法: generateAssignment() 函数:对应执行脚本的 -
相关文章
相关标签/搜索