flink-kafka

:helicopter::rocket: Hệ thống gợi ý sản phẩm thời gian thực dựa trên Flink. Flink thống kê độ hot của sản phẩm, đưa vào bộ nhớ cache Redis, phân tích thông tin nhật ký, đặt thẻ hồ sơ và bản ghi thời gian thực vào HBase. Sau khi người dùng gửi yêu cầu gợi ý, sắp xếp lại bảng xếp hạng độ hot dựa trên hồ sơ người dùng, kết hợp hai mô-đun gợi ý là lọc cộng tác và thẻ để thêm các sản phẩm liên quan cho từng sản phẩm trong bảng xếp hạng mới được tạo, và cuối cùng trả về danh sách người dùng mới.

Kho lưu trữ này tập trung giúp người đọc hiểu nhanh các thành phần Flink, bao gồm mã thực hành và tài liệu Flink, 200 kiến thức hướng dẫn về 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, các tính năng mới của Flink, Flink Partition, Flink Memory, v.v. Liên kết chi tiết xem tại: https://mp.weixin.qq.com/mp/appmsgalbum?__biz=Mzg5NDY3NzIwMA==&action=getalbum&album_id=2038088622687469575#wechat_redirect

Công cụ low-code để tự động hóa các hành động trên dữ liệu thời gian thực | Xử lý luồng cho người dùng