返回到文章

采纳

编辑于

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

kafka

命令:

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都加上,则可以运行