Node.js 中的 Kafka 消费者

Question

目前我正在使用 Node.js 实现 Kafka 队列。我可以在 Express 中创建简单的 API 并将数据推送到 Kafka（生产者）。

我目前对从 Kafka 获取数据感到震惊，我正在使用 node.js 的 Kafka-node 库。

我需要将消费者公开为 API 或后端服务。

所以请大家帮帮我。

Answer 1

这是一个使用kafka-node的消费者示例：https://blog.mimacom.com/blog/2017/04/07/apache-kafka-with-node-js/

Answer 2

试试这个“NodeJS 和 Kafka 入门” " - https://nodewebapps.com/2017/11/04/getting-started-with-nodejs-and-kafka/