Skip to content

Latest commit

 

History

History
29 lines (23 loc) · 460 Bytes

README.md

File metadata and controls

29 lines (23 loc) · 460 Bytes

Node.js Kafka模版

  • 可使用Node.js Produce資料至Kafka
  • 可使用Node.js 從Kafka Consume資料回來
  • 可從 sql_statement的資料夾中執行ksql statement

執行指令

安裝依賴

npm install

Kafka需先確定已啟動

  • 9092 port的Broker是啟動的狀態

Produce 資料至Kafka

npm run produce

從Kafka Consume資料

npm run consume

執行ksql

npm run ksql