GitHub topics: flink-kafka
TouK/nussknacker
Low-code tool for automating actions on real time data | Stream processing for the users.
Language: Scala - Size: 186 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 691 - Forks: 99
water8394/flink-recommandSystem-demo
:helicopter::rocket:基于Flink实现的商品实时推荐系统。flink统计商品热度，放入redis缓存，分析日志信息，将画像标签和实时记录放入Hbase。在用户发起推荐请求后，根据用户画像重排序热度榜，并结合协同过滤和标签两个推荐模块为新生成的榜单的每一个产品添加关联产品，最后返回新的用户列表。
Language: Java - Size: 4.47 MB - Last synced at: about 1 month ago - Pushed at: over 1 year ago - Stars: 4,389 - Forks: 1,476
mikeroyal/Apache-Flink-Guide
Apache Flink Guide
Size: 171 KB - Last synced at: 2 months ago - Pushed at: over 3 years ago - Stars: 57 - Forks: 8
crate/cratedb-flink-jobs
This repository accompanies the article "Build a data ingestion pipeline using Kafka, Flink, and CrateDB" and the "CrateDB Community Day #2".
Language: Java - Size: 8.48 MB - Last synced at: 20 days ago - Pushed at: 28 days ago - Stars: 5 - Forks: 3
yyb345/notes
大数据&后端技术体系笔记【多回顾、多练习、多总结沉淀】
Language: Java - Size: 38 MB - Last synced at: 10 months ago - Pushed at: 10 months ago - Stars: 2 - Forks: 0
suryadev99/stream_processing_website_click_data
Stream Processing of website click data using Kafka and monitored and visualised using Prometheus and Grafana
Language: Python - Size: 508 KB - Last synced at: 4 months ago - Pushed at: 12 months ago - Stars: 0 - Forks: 0
threeknowbigdata/flink_second_understand
该仓库专注于让读者秒懂Flink组件，包含Flink实战代码和文档、200个Flink教程知识点，Flink Datastream、Flink Table、Flink Window、Flink State、Flink Checkpoint、Flink Metrics、Flink Memory、Flink on standalone /yarn/k8s、Flink SQL、Flink CEP、Flink CDC、Flink UDF、PyFlink、Flink新特性、Flink Partition、Flink Memory等知识点。详细链接请看：https ://mp.weixin.qq.com/mp /appmsgalbum?__biz=Mzg5NDY3NzIwMA==&action=getalbum&album_id=2038088622687469575#wechat_redirect
Language: Java - Size: 58.7 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 646 - Forks: 174
BrooksIan/Flink2Kafka
A Flink applcation that demonstrates reading and writing to/from Apache Kafka with Apache Flink
Language: Java - Size: 2.98 MB - Last synced at: 17 days ago - Pushed at: almost 2 years ago - Stars: 20 - Forks: 7
LinMingQiang/sparkstreaming
:boom: :rocket: 封装sparkstreaming动态调节batch time(有数据就执行计算)；:rocket: 支持运行过程中增删topic；:rocket: 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL。
Language: Scala - Size: 258 KB - Last synced at: about 1 year ago - Pushed at: about 4 years ago - Stars: 182 - Forks: 83
seanpquig/flink-streaming-confluent
DeserializationSchema compatible with Confluent's KafkaAvroDecoder
Language: Java - Size: 16.6 KB - Last synced at: almost 2 years ago - Pushed at: about 9 years ago - Stars: 5 - Forks: 3
zqhxuyuan/kafka-book
《Kafka技术内幕》代码
Language: Java - Size: 816 KB - Last synced at: over 1 year ago - Pushed at: over 7 years ago - Stars: 195 - Forks: 71
isopropylcyanide/Websockets-Vertx-Flink-Kafka
A simple request response cycle using Websockets, Eclipse Vert-x server, Apache Kafka, Apache Flink.
Language: Java - Size: 85.4 MB - Last synced at: about 2 months ago - Pushed at: about 4 years ago - Stars: 16 - Forks: 7
sonhmai/streaming-pipeline
Building POC of streaming pipeline with Flink, Kafka, Pinot
Language: Scala - Size: 37.1 KB - Last synced at: over 2 years ago - Pushed at: almost 3 years ago - Stars: 2 - Forks: 0
froblesmartin/BachFinalProject
Project to compare Apache Spark Streaming vs Apache Flink.
Language: Java - Size: 42 KB - Last synced at: over 2 years ago - Pushed at: about 4 years ago - Stars: 1 - Forks: 1
yucl80/log-handle-tools
Language: Scala - Size: 133 KB - Last synced at: 3 months ago - Pushed at: almost 8 years ago - Stars: 0 - Forks: 1
