🚁🚀基于Flink实现的商品实时推荐系统。flink统计商品热度，放入redis缓存，分析日志信息，将画像标签和实时记录放入Hbase。在用户发起推荐请求后，根据用户画像重排序热度榜，并结合协同过滤和标签两个推荐模块为新生成的榜单的每一个产品添加关联产品，最后返回新的用户列表。
-
Updated
Feb 4, 2024 - Java
#
flink-kafka
Here are 19 public repositories matching this topic...
该仓库专注于让读者秒懂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=g…
flink-elasticsearch2-connector flink-dataset flink-kafka flink-cep flink-streaming flink-sql flink-table pyflink flink-cdc flink-udf flink-window flink-state
-
Updated
Jun 14, 2024 - Java
Low-code tool for automating actions on real time data | Stream processing for the users.
gui automation streaming real-time scala kafka big-data decision-making stream-processing apache-flink decisioning flink rules-engine low-code data-streaming decision-engine flink-kafka touk lowcode
-
Updated
Dec 16, 2024 - Scala
《Kafka技术内幕》代码
-
Updated
Dec 19, 2017 - Java
💥 🚀 封装sparkstreaming动态调节batch time(有数据就执行计算)；🚀 支持运行过程中增删topic；🚀 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL。
kafka spark splunk kudu hbase flink sparkstreaming flink-kafka ssc-dstream spark-kafka spark-es spark-kudu spark-hbase kafka-spark kafka-util es-shade sparkstreaming-kafka rabbitmq-util hbase-util kafka-ssl
-
Updated
Apr 15, 2021 - Scala
Apache Flink Guide
data-science streaming database stream-processing flink flink-stream-processing flink-kafka flink-streaming
-
Updated
Oct 14, 2021
A Flink applcation that demonstrates reading and writing to/from Apache Kafka with Apache Flink
-
Updated
Jul 23, 2023 - Java
A simple request response cycle using Websockets, Eclipse Vert-x server, Apache Kafka, Apache Flink.
-
Updated
Apr 14, 2021 - Java
基于Flink流处理的动态实时亿级电商全端用户画像系统
-
Updated
Apr 11, 2019
DeserializationSchema compatible with Confluent's KafkaAvroDecoder
-
Updated
May 23, 2016 - Java
Building POC of streaming pipeline with Flink, Kafka, Pinot
-
Updated
Sep 11, 2022 - Scala
This repository accompanies the article "Build a data ingestion pipeline using Kafka, Flink, and CrateDB" and the "CrateDB Community Day #2".
kafka apache-flink apache-kafka cratedb flink flink-examples flink-stream-processing flink-kafka cratedb-examples
-
Updated
Jun 1, 2024 - Java
Process streaming data from Kafka with Flink and store it in ElasticSearch
elasticsearch twitter kafka sentiment-analysis kafka-consumer flink flink-stream-processing flink-kafka
-
Updated
Mar 18, 2018 - Java
Project to compare Apache Spark Streaming vs Apache Flink.
benchmarking benchmark streaming kafka big-data spark apache spark-streaming flink flink-stream-processing spark-streaming-kafka flink-kafka
-
Updated
Jun 2, 2021 - Java
This code helps making a real time alert platform for IoT etc.
scala kafka sbt apache-flink kafka-streams flink-stream-processing flink-kafka flink-cep flink-kafka-consumer flink-table
-
Updated
Oct 14, 2019 - Scala
This is a basic example to show CEP in flink with kafka
scala patterns sbt cep kafka-consumer apache-flink apache-kafka kafka-producer kafka-streams kafka-connector flink-stream-processing flink-kafka flink-cep flink-kafka-consumer flink-connector
-
Updated
Oct 7, 2019 - Scala
Stream Processing of website click data using Kafka and monitored and visualised using Prometheus and Grafana
python git docker data kafka grafana psql prometheus kafka-topic kafka-streams dataengineering flink-stream-processing flink-kafka flink-metrics clickdata
-
Updated
Jul 11, 2024 - Python
java scala spark spark-streaming apache-flink flink flink-elasticsearch2-connector spark-kafka-integration flink-examples flink-kafka
-
Updated
Sep 7, 2017 - Scala
Improve this page
Add a description, image, and links to the flink-kafka topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the flink-kafka topic, visit your repo's landing page and select "manage topics."