文件名称：express-kafka-producer:将Node.js + Express请求直接发送到Kafka的中间件
文件大小：19KB
文件格式：ZIP
更新时间：2024-06-10 13:34:12
JavaScript
将Node.js + Express请求直接发送到Kafka的中间件 安装 将express-kafka-producer添加到您的package.json 例子 查看以获取有关如何使用中间件的有效示例 运行卡夫卡 有一个配置使测试更容易 用法 在您的Express应用中用作中间件 expressProducer = require('express-kafka-producer'); var kafka = { producer: { topic: 'my-node-topic' } }; app.get('/', expressProducer(kafka), function(req, res) { }); 选项 可用的选项有 verbose （ boolean ）：启用到kafka客户端的日志，正在发布的消息和错误，所有日志> KAFKA MIDDLEWARE字符
【文件预览】：
express-kafka-producer-master
----.gitignore(1KB)
----tasks()
--------options()
--------grunt-tasks.js(90B)
----README.md(6KB)
----tests()
--------message-tests.js(2KB)
--------middleware-tests.js(10KB)
--------default-partitioner-tests.js(2KB)
--------publish-tests.js(6KB)
----docker-compose.yml(291B)
----Gruntfile.js(642B)
----package.json(744B)
----start-kafka-shell.sh(139B)
----index.js(420B)
----example()
--------.gitignore(1KB)
--------README.md(167B)
--------package.json(530B)
--------worker.js(1KB)
--------index.js(2KB)
----.travis.yml(60B)
----lib()
--------default-partitioner.js(1KB)
--------publish.js(4KB)
--------middleware.js(4KB)
--------message.js(1KB)
----DOCKER.md(774B)