在NodeJS中创建主题时，将领导者分配给kafka主题的分区

问题描述

我只有一个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:

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

apache-kafka kafka-node