将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字符
评论0
最新资源