node.js - 如何在nodejs中创建带分区的kafka主题？

Question

我正在使用 kafka-node link用于创建 kafka 主题的 api。我没有找到如何创建带分区的 kafka 主题。

var kafka = require('kafka-node'),
    Producer = kafka.Producer,
    client = new kafka.Client(),
    producer = new Producer(client);
// Create topics sync
producer.createTopics(['t','t1'], false, function (err, data) {
    console.log(data);
});
// Create topics async
producer.createTopics(['t'], true, function (err, data) {});

producer.createTopics(['t'], function (err, data) {});// Simply omit 2nd arg

如何在 nodejs 中创建带分区的 kafka 主题。

Answer 1

从您的 node.js 应用程序执行 shell 脚本 $KAFKA_HOME/bin/kafka-topics.sh —create —topic topicname —partitions 8 —replication-factor 1 —zookeeper localhost:2181

其中$KAFKA_HOME是你安装Kafka的位置