增加 Kafka 中的复制因子会产生错误 - "There is an existing assignment running"



我正在尝试增加 Apache 中主题的复制因子 Kafka.In 以便这样做,我正在使用命令

kafka-reassign-partitions --zookeeper ${zookeeperid} --reassignment-json-file ${aFile} --execute

最初,我的主题的复制因子为 1,并且有 5 个分区,我正在尝试将其复制因子增加到 3。当我运行上述命令时,错误是 -"有一个现有分配正在运行"。我的 json 文件看起来像这样:

{
"version": 1,
"partitions": [
{
"topic": "IncreaseReplicationTopic",
"partition": 0,
"replicas": [2,4,0]
},{
"topic": "IncreaseReplicationTopic",
"partition": 1,
"replicas": [3,2,1]
}, {
"topic": "IncreaseReplicationTopic",
"partition": 2,
"replicas": [4,1,0]
}, {
"topic": "IncreaseReplicationTopic",
"partition": 3,
"replicas": [0,1,3]
}, {
"topic": "IncreaseReplicationTopic",
"partition": 4,
"replicas": [1,4,2]
}
]
}

我无法弄清楚我哪里错了。任何指示将不胜感激。

此消息表示已经执行了任何主题的另一个分配。 请稍后再试。然后你不会看到这条消息

相关内容

最新更新