GitHub - hanc1027/Nodejs_Run_KSQL: 使用Node.js執行KSQL Statement & 簡易Produce/ Consume

hanc1027 / Nodejs_Run_KSQL Public

Notifications You must be signed in to change notification settings
Fork 0
Star 0

使用Node.js執行KSQL Statement & 簡易Produce/ Consume

0 stars 0 forks Branches Tags Activity

Notifications

Name		Name	Last commit message	Last commit date
Latest commit History 6 Commits
ksql_statement		ksql_statement
.gitignore		.gitignore
README.md		README.md
config.js		config.js
consume.js		consume.js
package-lock.json		package-lock.json
package.json		package.json
produce.js		produce.js

Repository files navigation

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

About

使用Node.js執行KSQL Statement & 簡易Produce/ Consume

producer-consumer node-kafka ksql

Report repository

Releases

No releases published

Packages

No packages published

Languages

JavaScript 100.0%