文件名称：kafka-node-manager:kafka-node 的作业管理器
文件大小：11KB
文件格式：ZIP
更新时间：2024-07-01 03:32:26
JavaScript
Kafka 节点管理器 Kafka-node-manager 执行 kafka-node 处理作业的管理，并确保仅在作业完成时提交消息。 手术 KafkaJobManager 代表客户端读取和提交消息。 jobmanager 将使用从 kafka 读取的消息调用提供的客户端函数。 客户端可以限制传输中消息的数量，并可选择提供成功和失败的回调以及将失败消息发送到的主题。 var jobManager = new KafkaJobManager(clientFunction, zkConnection, consumerGroup, topic, inflightMessages, notifySuccess, notifyFailure, deadLetterTopic); 强烈建议使用来管理客户端进程的执行，因为在某些情况下需要强制重新连接。 安装 npm install kafka
【文件预览】：
kafka-node-manager-master
----.gitignore(587B)
----package.json(415B)
----LICENSE(1KB)
----index.js(66B)
----README.md(3KB)
----lib()
--------kafka()
----test()
--------test-consumer.js(399B)
--------test-producer.js(764B)