试图在卡夫卡建立消费者和生产者

我试图让一个简单的生产者-消费者流通过卡夫卡,使用 node-rdkafka

debug: 'all' 模式,这是我从日志中得到的:

test [0]: MessageSet with 1 message(s) delivered

消费者: Fetch topic test [0] at offset 38 (v2)

当生成消息时,使用者正在更改偏移量这一事实使我相信与代理的连接已正确设置和验证。

从不调用此事件:

consumer.on('data', function(m) {
    console.log("consumed", m)
});

我创建了一个用于测试的演示项目,您需要一个支持SASL\u SSL协议的Kafka代理才能使用它:

https://github.com/guysegal/kafka-example

具体来说,这是消费者代码:

https://github.com/guysegal/kafka-example/blob/master/src/consumer.ts

生产商代码:

https://github.com/guysegal/kafka-example/blob/master/src/producer.ts