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: 499 KB - Last synced: 1 day ago - Pushed: 1 day ago - Stars: 0 - Forks: 0

water8394/flink-recommandSystem-demo

:helicopter::rocket:基于Flink实现的商品实时推荐系统。flink统计商品热度，放入redis缓存，分析日志信息，将画像标签和实时记录放入Hbase。在用户发起推荐请求后，根据用户画像重排序热度榜，并结合协同过滤和标签两个推荐模块为新生成的榜单的每一个产品添加关联产品，最后返回新的用户列表。

Language: Java - Size: 4.47 MB - Last synced: 4 days ago - Pushed: 4 months ago - Stars: 4,197 - Forks: 1,446

TouK/nussknacker

Low-code tool for automating actions on real time data | Stream processing for the users.

Language: Scala - Size: 139 MB - Last synced: about 2 months ago - Pushed: about 2 months ago - Stars: 599 - Forks: 89

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.47 MB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 2 - Forks: 2

LinMingQiang/sparkstreaming

:boom: :rocket: 封装sparkstreaming动态调节batch time(有数据就执行计算)；:rocket: 支持运行过程中增删topic；:rocket: 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL。

Language: Scala - Size: 258 KB - Last synced: about 2 months ago - Pushed: about 3 years ago - Stars: 182 - Forks: 83

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.6 MB - Last synced: 7 months ago - Pushed: almost 2 years ago - Stars: 586 - Forks: 159

seanpquig/flink-streaming-confluent

DeserializationSchema compatible with Confluent's KafkaAvroDecoder

Language: Java - Size: 16.6 KB - Last synced: 10 months ago - Pushed: about 8 years ago - Stars: 5 - Forks: 3

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: 11 months ago - Pushed: almost 4 years ago - Stars: 18 - Forks: 6

zqhxuyuan/kafka-book

《Kafka技术内幕》代码

Language: Java - Size: 816 KB - Last synced: 7 months ago - Pushed: over 6 years ago - Stars: 195 - Forks: 71

yyb345/notes

大数据技术体系笔记【多回顾、多练习、多总结沉淀】

Language: Java - Size: 37.6 MB - Last synced: about 1 year ago - Pushed: about 1 year ago - Stars: 2 - Forks: 0

mikeroyal/Apache-Flink-Guide

Apache Flink Guide

Size: 171 KB - Last synced: over 1 year ago - Pushed: over 2 years ago - Stars: 16 - Forks: 4

sonhmai/streaming-pipeline

Building POC of streaming pipeline with Flink, Kafka, Pinot

Language: Scala - Size: 37.1 KB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 2 - Forks: 0

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: about 1 year ago - Pushed: about 3 years ago - Stars: 14 - Forks: 6

froblesmartin/BachFinalProject

Project to compare Apache Spark Streaming vs Apache Flink.

Language: Java - Size: 42 KB - Last synced: about 1 year ago - Pushed: about 3 years ago - Stars: 1 - Forks: 1

yucl80/log-handle-tools

Language: Scala - Size: 133 KB - Last synced: over 1 year ago - Pushed: over 6 years ago - Stars: 0 - Forks: 1