Node.js 操作kafka

Node.js 操作kafka

基础知识可参考：douzixiansheng/MQ​github.com/douzixiansheng/MQ/blob/master/kafka_basic.md

1.准备好kafka环境，没有安装的伙伴可以参考 （讲解了linux如何安装kafka）：

douzixiansheng/MQ​github.com/douzixiansheng/MQ/blob/master/kafka_linux_install.md

2. 安装依赖 kafka-node 模块,编写package.json

3. 编写生产者与消费者 具体api可以参考官网：

kafka-node​www.npmjs.com/package/kafka-node

生产者：

消费者：

4.执行生产者脚本

执行消费者脚本

可以看到每隔两秒生产者往主题topic(broadcast) 上生产消息，消费者从主题上拉取消息