在 Kafka 中增加复制因子会出现错误 - “有一个现有的分配正在运行”

Question

我正在尝试增加 Apache Kafka 中某个主题的复制因子。为此，我使用了命令

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

最初我的主题的复制因子为 1，有 5 个分区，我试图将它的复制因子增加到 3。我的主题中有相当多的消息。当我运行上述命令时，错误是 - "There is an existing assignment running"。我的 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]
        }
    ]
}

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

Answer 1

此消息意味着已经有任何主题的另一个分配正在执行。请稍后再试。那么你就不会看到这条消息