Hi All, I am facing error while creating topic manually using kafka-node client. The code is mentioned below.
Can anyone help please? let topicsToCreate = [{ topic: topicName, partitions: 1, replicationFactor: 2 }]; admin.createTopics(topicsToCreate, (err, data) => { if (err) { console.log(err) } else { console.log(data) } }); The error it is throwing is given below :: Error: No broker with id undefined at KafkaClient.sendRequestToBroker (/Kafka/KafkaDemo/node_modules/kafka-node/lib/kafkaClient.js:1089:21) at getController (/Kafka/KafkaDemo/node_modules/kafka-node/lib/kafkaClient.js:1190:10) at loadMetadata (/Kafka/KafkaDemo/node_modules/kafka-node/lib/kafkaClient.js:287:12) at async.series (/Kafka/KafkaDemo/node_modules/kafka-node/lib/kafkaClient.js:892:7) at /Kafka/KafkaDemo/node_modules/async/dist/async.js:3888:9 at /Kafka/KafkaDemo/node_modules/async/dist/async.js:473:16 at replenish (/Kafka/KafkaDemo/node_modules/async/dist/async.js:1006:25) at iterateeCallback (/Kafka/KafkaDemo/node_modules/async/dist/async.js:995:17) at /Kafka/KafkaDemo/node_modules/async/dist/async.js:969:16 at /Kafka/KafkaDemo/node_modules/async/dist/async.js:3885:13