在原kafka集群动态增加分区后,发现刚增加的分区和原分区数据量差距太大?

无心1990 发布于 06/22 15:12
阅读 272
收藏 0

现在遇到了一个kafka集群分区扩容问题,详细情况为:

我现在kafka 集群为5台机器,现在的主题中分区数为8个,但是没有添加新的机器,只是想将现在的分区数改为10个,利用kafka自带的脚本,执行生产迁移计划、执行迁移计划、验证迁移计划,这些步骤都能成功,但是在kafka tools工具里面查看新增加的分区数和原来分区数据总量差距很大,且在消费的时候差距也很大。吞吐量严重下降,有大神吗知道怎么修改吗?

注意:其中的8/9为新增加的分区,0-7为旧分区。

加载中
返回顶部
顶部