spring kafka 2.9.5+ 支持配置重试头（如 retry_topic-attempts）的覆盖行为，避免在逐级重试主题中不断累积相同头字段，从而防止消息体积膨胀和 dlt 消息冗余。
在使用 Spring Kafka 的非阻塞重试机制（Retry Topic）时，框架会自动为每条消息添加一组关键重试控制头，例如：
- retry_topic-attempts
- retry_topic-backoff-timestamp
- retry_topic-original-timestamp
默认情况下（Spring Kafka 多值追加模式（multi-value append）：每次转发到下一个重试主题（如 retry_0 → retry_1 → dlt）时，新值会被追加而非替换，导致同一头字段携带多个时间戳或计数，最终在死信主题（DLT）中出现三份甚至更多冗余数据。这不仅增大序列化负载，还可能干扰下游消费者对重试状态的准确解析。
✅ 解决方案：启用头覆盖模式（Header Overwrite）
自 Spring Kafka 2.9.5 起，可通过 RetryTopicConfiguration 显式启用头覆盖策略，确保每个重试层级仅保留最新、有效的单值头：
@Bean
public RetryTopicConfiguration retryTopicConfiguration() {
return RetryTopicConfigurationBuilder
.newInstance()
.maxAttempts(3)
.exponentialBackoff(1000L, 2.0, 10_000L) // 初始延迟1s，倍增，上限10s
.useSingleTopicForAllAttempts(false)
.headerStrategy(RetryTopicHeaders.STRATEGY_OVERWRITE) // ? 关键配置：覆盖而非追加
.create();
}⚠️ 注意事项：
- RetryTopicHeaders.STRATEGY_OVERWRITE 是推荐生产配置，可显著降低消息体积并提升 DLT 可读性；
- 若需兼容旧版行为（如调试追踪全链路重试路径），可选用 STRATEGY_APPEND（默认值），但应评估其对消息大小与消费逻辑的影响；
- 当前版本（截至 3.1.x）尚未提供类似 stripOriginalExceptionHeaders=true 的全局开关来自动清理历史重试头；如有此需求，建议在 Spring Kafka GitHub 提交 Feature Request（参考已存在的 PR #2529）；
- 自定义 RecordInterceptor 或 ProducerInterceptor 中若手动操作重试头，请确保与 STRATEGY_OVERWRITE 行为一致，避免冲突。
? 总结：升级至 Spring Kafka ≥ 2.9.5 并显式设置 headerStrategy(RetryTopicHeaders.STRATEGY_OVERWRITE)，是解决重试头冗余积累、保障消息轻量化与语义清晰性的标准实践。
