文件名称:kafka-stream:流兼容的 kafka 客户端
文件大小:3KB
文件格式:ZIP
更新时间:2024-07-14 07:18:41
JavaScript
卡夫卡流 Node 0.10 Stream 兼容 kafka 消费者 警告:这仍处于试验阶段,不应在生产中使用。 概述 该模块旨在为 Prozess 的 kafka Consumer 提供一个简单且流兼容的接口。 它隐藏了从 kafka 流读取的轮询复杂性。 安装 npm install kafka-stream 用法 var KafkaStream = require('kafka-stream'); var myStream = new KafkaStream({ host: 'localhost', port: '9092', partition: 0, topic: 'test' }); myStream.start(function(err) { if (err) { handleError(err); return; } mySt
【文件预览】:
kafka-stream-master
----index.js(2KB)
----package.json(1KB)
----test()
--------index.js(216B)
----.gitignore(24B)
----README.md(732B)