【文件属性】:
文件名称:kafka-streams-running-topN:使用Apache Kafka Streams运行前N个聚合
文件大小:2.8MB
文件格式:ZIP
更新时间:2021-02-05 07:58:00
nodejs javascript express node kafka
kafka-streams-running-topN
使用Apache Kafka Streams运行Top N聚合
以下博客文章中讨论了有关此应用程序的详细信息:
Apache Kafka Streams –按维度分组的运行Top-N聚合–往返Kafka主题-https:
Kafka Streams入门–针对Kafka主题构建流分析Java应用程序-https:
NodeJS –随机延迟将消息发布到Apache Kafka主题以基于CSV文件中的记录生成示例事件-https:
Apache Kafka研讨会–演示和动手实验入门-https:
此存储库中有四个应用程序:
k
【文件预览】:
kafka-streams-running-topN-master
----kafka-node-express-topN-sse()
--------public()
--------sse.js(2KB)
--------topNreport.js(3KB)
--------package.json(465B)
----Kafka_Streams_TopN.pptx(2.93MB)
----kafka-node-mongodb-topN()
--------topNKafkaConsumerMongoDBWriter.js(3KB)
--------topNmongodbWriter.js(2KB)
--------package.json(430B)
----kafka-node-TopN-Report()
--------KafkaCountryStreamsConsumer.js(2KB)
--------package.json(829B)
----README.md(3KB)
----kafka-node-countries()
--------countries2.csv(38KB)
--------package.json(862B)
--------KafkaCountryProducer.js(3KB)
----Kafka-Streams-Country-TopN()
--------src()
--------pom.xml(1KB)
----.gitignore(235B)
网友评论
相关文章
- kafka-streams-sandbox:Apache Kafka流(KStream和KTable)
- Streaming Architecture - New Designs Using Apache Kafka and MapR Streams
- Streaming Architecture New Designs Using Apache Kafka and MapR Streams
- tensorflow-tfserving-cloud-apache-kafka-streams:使用Apache Kafka,Kafka Streams和已部署到TF-Serving(Google Cloud ML Engine)的TensorFlow模型进行模型推断