kafka-node-manager:kafka-node 的作业管理器

Kafka 节点管理器 Kafka-node-manager 执行 kafka-node 处理作业的管理，并确保仅在作业完成时提交消息。 手术 KafkaJobManager 代表客户端读取和提交消息。 jobmanager 将使用从 kafka 读取的消息调用提供的客户端函数。 客户端可以限制传输中消息的数量，并可选择提供成功和失败的回调以及将失败消息发送到的主题。 var jobManager = new KafkaJobManager(clientFunction, zkConnection, consumerGroup, topic, inflightMessages, notifySuccess, notifyFailure, deadLetterTopic); 强烈建议使用来管理客户端进程的执行，因为在某些情况下需要强制重新连接。 安装 npm install kafka