【文件属性】：
文件名称：kafka-streams：等同于nodejs的kafka-streams
文件大小：344KB
文件格式：ZIP
更新时间：2021-02-04 04:22:43
nodejs node kafka big-data streams
节点卡夫卡流
// suggested Node.js version: v12.16.1
npm install --save kafka-streams
const { KafkaStreams } = require ( "kafka-streams" ) ;
const config = require ( "./config.json" ) ;
const factory = new KafkaStreams ( config ) ;
const kstream = factory . getKStream ( "input-topic" ) ;
const ktable = fa
【文件预览】：
kafka-streams-master
----.eslintignore (38B)
----package.json(4KB)
----.github()
--------workflows()
----test()
--------int()
--------mocha.opts(7B)
--------unit()
--------test-config.ts(1KB)
--------utils()
----website()
--------docs()
--------package.json(775B)
--------static()
--------src()
--------docusaurus.config.js(2KB)
--------sidebars.js(150B)
--------.gitignore(233B)
--------README.md(721B)
--------yarn.lock(435KB)
--------babel.config.js(89B)
----LICENSE(1KB)
----src()
--------types.ts(12KB)
--------lib()
--------index.ts(261B)
----.npmignore(96B)
----.eslintrc.js(596B)
----tsconfig.json(215B)
----examples()
--------mergeTopics.js(1KB)
--------consumeFromTopic.js(1002B)
--------consumeOneProduceTwo.js(873B)
--------window.js(1KB)
--------consumeOneProduceTwoTopics.js(1KB)
--------wordCount.js(2KB)
--------produceToTopic.js(898B)
--------fieldSum.js(680B)
--------topicAsTable.js(2KB)
--------topicExtractor.js(2KB)
----.gitignore(641B)
----CHANGELOG.md(7KB)
----kafka-setup()
--------stop.sh(128B)
--------generate-certs.sh(2KB)
--------docker-compose.yml(1KB)
--------start.sh(463B)
----.dockerignore(21B)
----README.md(7KB)
----yarn.lock(137KB)
----.editorconfig(179B)