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”,不超过三级。策略需在容灾与压测中验证。

发表评论 取消回复