NATS JetStream 流存储与消息语义(Ack、Deliver Policy、Retention)关键实践与参数Ack:显式确认(`AckPolicy=Explicit`);未确认重投递与上限控制。Deliver Policy:`All/Last/ByStartSequence/ByStartTime` 控制起始位点。Retention:`Limits/WorkQueue/Interest` 保留策略与存储上限。验证方法压测不同起始策略与 Ack 行为;统计重复与丢失率。观察存储利用与保留效果;设置告警与阈值。故障演练:消费者崩溃与恢复的位点与重投递。注意事项幂等处理与去重策略;避免重复导致副作用。合理选择 Retention 与存储限制;避免膨胀。监控消费者延迟与堆积,及时扩缩与优化。

发表评论 取消回复