在原kafka集群动态增加分区后,发现刚增加的分区和原分区数据量差距太大?
现在遇到了一个kafka集群分区扩容问题,详细情况为:
我现在kafka 集群为5台机器,现在的主题中分区数为8个,但是没有添加新的机器,只是想将现在的分区数改为10个,利用kafka自带的脚本,执行生产迁移计划、执行迁移计划、验证迁移计划,这些步骤都能成功,但是在kafka tools工具里面查看新增加的分区数和原来分区数据总量差距很大,且在消费的时候差距也很大。吞吐量严重下降,有大神吗知道怎么修改吗?
注意:其中的8/9为新增加的分区,0-7为旧分区。
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(1)
分区增加后 对应的硬盘设备没有增加 生产吞吐下降是正常的。。。。 ssd可能会好一点