node.js - 在nodeJS中创建主题时将领导者分配给kafka主题的分区

Question

我有单个 kafka 代理，并且正在使用 kafka-node 在 nodeJS 中实现 kafka。我想创建一个包含 3 个分区的主题。这样做时，出现的问题是只有第一个分区正在分配领导者，而其他两个分区没有获得领导者。我想为所有分区分配领导者。谁能告诉我我该怎么做？提前致谢。

var client = new kafka.KafkaClient();
    var topic = 't-26';
    var topicsToCreate = [
        {
            topic: topic,
            partitions: 3,
            Leader: 0,
            replicationFactor: 1,
            replicaAssignment: [
            {
              partition: 0,
              replicas: [0]
            },
            {
                partition: 1,
                replicas: [1]
            },
            {
                partition: 2,
                replicas: [2]
            }
          ]
        },
        ];
        client.createTopics(topicsToCreate, (error, result) => {
             console.log(result);
        });

主题创建如下 -

Topic: t-26     PartitionCount: 3       ReplicationFactor: 1    Configs:
        Topic: t-26     Partition: 0    Leader: 0       Replicas: 0     Isr: 0
        Topic: t-26     Partition: 1    Leader: none    Replicas: 1     Isr:
        Topic: t-26     Partition: 2    Leader: none    Replicas: 2     Isr:

Answer 1

您正在“全局”定义领导者在具有 id 的代理上，0而您希望拥有分区1并2位于其他代理上。当您将复制定义为一个时，这自相矛盾。删除关于 的部分Leader，它应该会自动在您想要的代理上创建分区领导者。

Answer 2

由于@mike，我得到了提示并解决了这个问题。我做了以下 -

删除leader=0所有副本并将其设置为 0replicas: [0]