NATS JetStream 流与消费者治理（2025）

一、Stream 与存储

• Stream：主题分组与副本；存储策略与保留（Limits/WorkQueue）。
• 分片与副本：按吞吐与可用性设副本；跨集群镜像与转发。

二、Consumer 与投递

• Consumer：Ack Policy（Explicit/All/None）与 Ack Wait；Delivery Policy（All/Last/By Start）。
• 重试与限流：最大重试次数与 backoff；对消费者设置并发与速率上限。
• 去重：以消息 ID/业务键实现幂等，避免重复处理。

三、观测与维护

• 指标：滞留消息、Ack 超时、重试与丢弃；消费者健康。
• 维护：修剪历史、分片再均衡、故障转移演练。
• 安全：命名空间与权限治理。

注意事项

• 关键词（JetStream、Stream、Consumer、Ack Policy、Exactly-Once 近似）与正文一致。
• 分类为“数据/消息/NATS”，不超过三级。
• 策略需在容灾与压测中验证。