在kafka中使用多个主题生成消息-node.js？答案

【问题标题】：Producing message using multiple topics in kafka - node.js?在kafka中使用多个主题生成消息-node.js？
【发布时间】：2014-01-04 20:37:51
【问题描述】：

我在我的应用程序中使用Prozess kafka 库来生成日志。使用单个主题效果很好。

代码

    var Producer = require('prozess').Producer;
    var eventKafkaProducer = new Producer('triggerEventTopic', {
        host : 'localhost'
    });
    eventKafkaProducer.connect();
    eventKafkaProducer.on('error', function(err) {
        console.log("Error occurred in kafka producer", err);
     });
    eventKafkaProducer.on('brokerReconnectError', function(err) {
        console.log("could not reconnect kafka", err);
    });

要求

如何设置多个主题

Prozess 库是否支持多主题？

【问题讨论】：

标签： node.js apache-kafka

【解决方案1】：

所以我没有使用这个库，但是基于 api 看起来你只需要创建另一个生产者。所以：

var Producer = require('prozess').Producer;

// topic one:
var ops_one = {
  // some options
}

var one = new Producer('one', opts_one)
producer.connect()
// etc.

// topic two:
var opts_two = {
  // some options
}}

var two = new Producer('two', opts_two)
two.connect()

现在，当您有应该在主题 1 中发布的内容时，您只需致电 one.send("Hey everybody, I'm producer one")，您也会为 two 做同样的事情。

【讨论】：