【文件属性】:
文件名称:node-kafka:未维护。 见下文
文件大小:10KB
文件格式:ZIP
更新时间:2021-05-14 02:08:12
JavaScript
未维护
我不再维护node-kafka。
查看以下node-kafka分支:
或使用Prozess,另一个node.js kafka库:
旧版说明:
Kafka JavaScript API
使用node.js与 (LinkedIn的基于磁盘的消息队列)进行交互
起床并跑步
1安装kafka
npm install kafka
2启动zookeeper,kafka服务器和使用者(请参阅 )
3发布并使用一些消息!
var kafka = require('kafka')
new kafka.Consumer().connect().subscribeTopic('test').on('message', function(topic, message) {
console.log("Consumed message:", message)
})
var producer =
【文件预览】:
node-kafka-master
----.gitignore(18B)
----README.md(2KB)
----Changelog(766B)
----examples()
--------produce.js(241B)
--------consume.js(365B)
--------client.js(1KB)
--------consume-last-offset.js(1KB)
----LICENSE(1KB)
----kafka.js(163B)
----package.json(694B)
----lib()
--------requestTypes.js(112B)
--------Producer.js(1KB)
--------Consumer.js(2KB)
--------Connection.js(994B)
--------Client.js(8KB)
--------error.js(337B)