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