【发布时间】:2017-06-02 22:42:17
【问题描述】:
我想将 Kafka 与我的 Node.JS 服务一起用作消息代理,并在 kafka-node 和 node-rdkafka 库之间进行辩论。
我开始测试 kafka-node 的功能(该库似乎更受欢迎)并且能够创建生产者,使用它写入 Kafka,创建消费者,并使用它从 Kafka 读取。 但是,我注意到该库目前不支持某些 Kafka 功能,例如写入时间戳和 lz4 压缩(我使用的 Scala 驱动程序支持的功能)。
是否有人在 kafka-node(或 node-rdkafka)中遇到这些或其他挫折并因此决定使用另一个库?
【问题讨论】:
-
我们都测试过。 rdkafka 上的 producer 缓冲消息,然后根据消息的大小和数量发送到 kafka,因此在 broker 关闭时不会出错。 kafka-node 中的消费者在手动提交方面存在问题,这在我们的案例中是必需的。所以我们决定让生产者在 kafka-node 上,消费者在 node-rdkafka 上。
标签: node.js apache-kafka