接上篇文章 【kafka KSQL】游戏日志统计分析（2），本文主要通过实例展示KSQL的连接查询功能。 创建另一个topic {代码…} 往新topic中写入数据 {代码…} 从prop-normalized主题创建Stream {代码…} 重新设置RO…

接上一篇文章【kafka KSQL】游戏日志统计分析（1），展示一下KSQL WINDOW 功能的使用。 测试用日志数据： {代码…} KSQL三种Window 统计每2分钟内完成对局大于等于3局的玩家 根据时间窗口（Tumbling window）建…

【kafka KSQL】游戏日志统计分析（1） 以游戏结算日志为例，展示利用KSQL对日志进行统计分析的过程。 启动confluent {代码…} 查看kafka主题列表 {代码…} 创建接受游戏结算日志的topic {代码…} 使用生产者命…

并发(Concurrency): 问题域中的概念—— 程序需要被设计成能够处理多个同时（或者几乎同时）发生的事件