# 云消息队列 Kafka 版 #
0
关注
10043内容
|
小红书如何实现高效推荐？解密背后的大数据计算平台架构
小红书作为生活分享类社区，目前有8500万用户，年同比增长为300%，大约每天有30亿条笔记在发现首页进行展示。推荐是小红书非常核心且重要的场景之一，本文主要分享在推荐业务场景中小红书的实时计算应用。
|
单车骑行流数据分析
本文实现了一个基于SparkStreaming 的流数据处理系统，使用骑行数据发送至Kafka作为数据源，使用SparkStreaming对流数据进行处理（无状态、有状态：window、updateByKey），并将其持久化至Mysql、可视化为图表
|
k8s与日志--采用golang实 现Fluent Bit的output插件
s" "time" "unsafe" "github.com/Shopify/sarama" "github.com/fluent/fluent-bit-go/output" "github.com/ugorji/go/codec"
)
var (
brokers []string
producer sarama.
|
使用Docker（Mac）搭建 Nginx/Openresty - Kafka - kafkaManager
本文默认读者已经对Docker有一定了解，且清楚使用Docker进行部署的优势。
1.安装Docker（Mac）
官网：https://docs.docker.
Flink Weekly | 每周社区动态更新 - 20200114
本文为 Flink Weekly 的第四期，由 Forward Xu 整理，主要内容包括：Flink 1.10 版本的发布测试，SQL catalog 读取关系数据库 schema 的相关建议以及 Flink Forward 旧金山的演讲邀请。
Demo：基于 Flink SQL 构建流式应用
本文所有的实战演练都将在 Flink SQL CLI 上执行，全程只涉及 SQL 纯文本，无需一行 Java/Scala 代码，无需安装 IDE。
免费试用