reassign partition加throttle限制,一定要将该topic下的所有的partition都加上吗?

恋茶慕雨 发表于: 2018-07-13   最后更新时间: 2019-06-29 00:26:39   2,612 游览

命令:

kafka-reassign-partitions.sh --execute --zookeeper 10.23.58.141:2181/kafka --reassignment-json-file file.json --throttle 50000000

file.json:

{"partitions":[{"topic":"test","partition":2,"replicas":[2,3]}]}

执行partition重新分配的时候,若加上throttle限制,会报错。 java.util.NoSuchElementException: key not found: [test,1] 只有当把所有的partition都加上,则可以运行

发表于 2018-07-13
添加评论

没看懂额。

恋茶慕雨 -> 半兽人 6年前

不好意思,没有写明白。
我在执行命令kafka-reassign-partitions.sh --execute --zookeeper 10.23.58.141:2181/kafka --reassignment-json-file file.json 的时候,加上--throttle 50000000的限制,会报错 java.util.NoSuchElementException。
但是如果我执行命令不加--throttle 50000000的限制,运行是成功的,或者在json文件中把该partition所有的3个replicas都写上,也是可以运行成功的,不知道原因是什么。

然后我的file.json是{"partitions":[{"topic":"test","partition":2,"replicas":[2,3]}]},这个partition有3个replicas。

你的答案

查看kafka相关的其他问题或提一个您自己的问题