在一个项目中,Node.js应用程序连接到Kafka消息队列,并从队列中获取所有消息。 我搜索并找到了两个包kafka-node和kafka-streams。 哪种套餐适合这里?
https://www.npmjs.com/package/kafka-node
https://www.npmjs.com/package/kafka-streams
这两个库都可以,问题是您想要进行流处理还是只访问消息并在自定义代码中进行处理。 简单的客户机将是容易和向前的。 streams版本为实时处理和聚合提供了更多特性,但学习曲线陡峭!