spring kafka中不可重试异常需继承nonretriabletopicexception或显式排除，捕获后同步发送至dlt并手动提交offset，避免进入重试链；dlt消息应结构化包含原始上下文与异常详情，配合独立消费组与告警机制。
Java中Kafka消费端抛出不可重试的自定义 NonRetriableException 时，不能走常规重试流程，需绕过重试机制、立即转发到死信队列（DLT）。关键在于：**不让异常进入重试拦截链，而是主动捕获并同步发送到DLT主题**。
明确标识不可重试异常
让Spring Kafka或KafkaListener能识别该异常无需重试。推荐方式是让自定义异常继承 org.springframework.kafka.listener.NonRetriableTopicException（Spring Kafka 2.8+），或实现 org.springframework.kafka.listener.RetryableTopicException 的反向语义（不推荐手动实现接口，优先用内置类）。
- 若使用 Spring Kafka ≥2.8：直接继承
NonRetriableTopicException - 若版本较低：可配合
@RetryableTopic的exceptions = { }显式排除该异常，使其不参与重试 - 避免仅靠异常名判断——必须通过类型匹配，否则重试拦截器可能仍尝试重试
在监听器内主动捕获并投递DLT
最可靠的方式不是依赖框架自动路由，而是在 @KafkaListener 方法中 try-catch 捕获 NonRetriableException，然后调用 KafkaTemplate 同步发送到DLT主题（如 topic-name.DLT），再手动提交offset（防止重复消费）。
- DLT消息建议包含原始record + 异常堆栈 + 时间戳 + 原因标签（如
"non_retriable"） - 使用
kafkaTemplate.send(topic, key, value).get()确保投递成功后再提交offset - 提交offset需通过
Acknowledgment.acknowledge()或ContainerAwarePartitionOffsetManager显式控制
禁用对该异常的自动重试配置
即使异常被标记为 non-retriable，若全局配置了 @RetryableTopic 且未排除该类型，仍可能触发默认重试行为。务必检查以下配置：
-
@RetryableTopic(attempts = "3", backoff = @Backoff(delay = 1000))中的exceptions属性是否显式列出所有可重试异常，把NonRetriableException排除在外 - 或设置
notRetryableExceptions = { NonRetriableException.class }（Spring Kafka 3.0+ 支持） - 确认
DefaultErrorHandler未将该异常纳入重试列表（例如未配置retryableExceptions包含它）
DLT消息格式与后续处理建议
DLT不是垃圾桶，而是可观测性和人工介入入口。建议结构化记录信息：
- value 使用 JSON，包含字段：
originalTopic、partition、offset、timestamp、key、payload（base64或字符串）、exceptionClass、message、stackTrace - 为DLT主题单独配置独立的消费者组，避免和主消费逻辑耦合
- 配套告警规则（如DLT积压 > 0 且持续5分钟）和人工处理SOP（如查日志、修复数据、手动重放）
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
