主要观点：现代航班预订系统常通过分布式微服务进行流票价更新和预订，管道需有重试恢复能力，核心策略是幂等性，即每个事件携带唯一标识符，防止重复预订或过时定价。
关键信息：

• 实践中给每个票价请求分配唯一事件 ID 或幂等性密钥，如航空公司预订 API 附加唯一请求令牌，下游消费者记录已处理的 ID 避免重复处理。
• Kafka 消费者应将每条消息视为可能多次交付，默认若未提交偏移量时抛出异常会重发，处理失败可重试，多次重试后应将消息路由到死信队列（DLQ）避免无限循环。
• 清楚区分需重试和应停止的错误， transient 错误触发自动重试，permanent 错误直接进入 DLQ，代码中要特殊处理。
• 管道可尝试回退逻辑，如定价服务故障时使用缓存价格，还可设计定期重新处理作业，处理 DLQ 或重试主题中的消息，要尊重幂等性密钥。
• 所有组件应发出清晰日志和指标，将错误消息路由到 DLQ 并可监控，如 Datadog 可用于跟踪 Kafka 管道流量等指标，帮助发现问题。
  重要细节：
• 生产者确保 ID 真正唯一，常用 UUID 或订单 ID + 时间戳组合键，消费者在缓存或数据库中保存已处理的 ID。
• Kafka 消费者默认至少一次交付语义，处理失败时让异常传播触发重试，Spring-Kafka 支持错误处理程序在多次失败后将记录发送到 DLQ 主题。
• 回退逻辑可使用缓存价格或默认费率，设计定期重新处理作业，如重新发布错过的事件或从 DLQ 重播。
• 实现这些实践可打造健壮的票价管道，如防止重复预订、避免意外重播、及时处理错误等，通过综合方法确保系统完整性和客户信任。