NATS JetStream 流存储与消息语义(Ack、Deliver Policy、Retention)

关键实践与参数

  • Ack:显式确认(AckPolicy=Explicit);未确认重投递与上限控制。
  • Deliver Policy:All/Last/ByStartSequence/ByStartTime 控制起始位点。
  • Retention:Limits/WorkQueue/Interest 保留策略与存储上限。

验证方法

  • 压测不同起始策略与 Ack 行为;统计重复与丢失率。
  • 观察存储利用与保留效果;设置告警与阈值。
  • 故障演练:消费者崩溃与恢复的位点与重投递。

注意事项

  • 幂等处理与去重策略;避免重复导致副作用。
  • 合理选择 Retention 与存储限制;避免膨胀。
  • 监控消费者延迟与堆积,及时扩缩与优化。
点赞(0) 打赏

评论列表 共有 0 条评论

暂无评论
立即
投稿
网站二维码

微信公众账号

微信扫一扫加关注

发表
评论
返回
顶部
/* 跳过导航链接 (无障碍) */ position: absolute; top: -100px; left: 15px; z-index: 99999; padding: 8px 16px; background: #007bff; color: #fff; font-size: 14px; border-radius: 0 0 4px 4px; text-decoration: none; transition: top 0.2s; } top: 0; outline: 3px solid #0056b3; }