流处理

【背景】 在分布式系统中，消息中间件是「数据一致性」与「系统性能」的终极战场。我们团队在 2018 年从 RabbitMQ 迁移至 Kafka 时，曾用 3 个月验证了「高吞吐」的诱惑，但也踩中了「Exactly-Once 语义」的坑。 【

«结论先行：「会话（session）数」看起来是个简单的去重计数，但它是一个有状态的流式聚合——切分阈值、事件到达顺序、去重键粒度三个自由度任一不同，同一批事件就会算出 1.5~2 倍的 session 数。本文给一套用 "lag()" 物