1

在一个项目中,Node.js 应用程序连接到 Kafka 消息队列并从队列中获取所有消息。我搜索并找到了两个包kafka-nodekafka-streams。哪个包适合这里?

https://www.npmjs.com/package/kafka-node

https://www.npmjs.com/package/kafka-streams

4

1 回答 1

0

这两个库都可以,问题是您是要进行流处理还是只访问消息并在自定义代码中进行处理。简单的客户端将是简单而直接的。流版本为实时处理和聚合提供了更多功能,但学习曲线陡峭!

于 2020-06-15T13:50:24.070 回答