【文件属性】：
文件名称：express-kafka-producer:将Node.js + Express请求直接发送到Kafka的中间件
文件大小：19KB
文件格式：ZIP
更新时间：2021-05-21 19:47:32
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)