科技资讯

NATS JetStream 流存储与消息治理(2025)

# NATS JetStream 流存储与消息治理(2025) JetStream 提供持久化与重放能力,适合轻量事件与队列场景。 ## 一、主题与流 - 流定义:设置存储、保留与分段参数。 - 主题设计:命名与层级便于路由与权限控制。 ## 二、订阅与投递 - 推/拉订阅:适配不同消费模型与背压。 - Ack 与重试:对失败消息进行重试与死信处理。 ## 三、观测与成本 - 指标:积压与

ClickHouse 物化视图实时聚合与去重治理(2025)

# ClickHouse 物化视图实时聚合与去重治理(2025) ## 一、表与视图设计 - 明细表:存储原始事件;索引按查询模式设计。 - 物化视图(物化视图):将明细写入 `AggregatingMergeTree` 进行 `实时聚合` 与 `去重`。 ## 二、聚合与去重 - 聚合函数:`sum/count/uniqExact/argMax` 等;按业务选择。 - 去重:使用 `uniq

Kafka MirrorMaker2 跨区域复制与一致性治理(2025)

# Kafka MirrorMaker2 跨区域复制与一致性治理(2025) ## 一、拓扑与链路 - 拓扑:源集群→(MirrorMaker2)→ 目标集群,多区域互备;避免环路。 - 连接器:配置 `replication.policy.class` 与心跳/检查点主题,确保位点同步。 ## 二、延迟与吞吐 - 延迟(延迟):监控复制延迟与网络 RTT;按批大小与并发调节。 - 吞吐:压缩