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) 上生産消息，消費者從主題上拉取消息