必须抛出RetriableException子类才能触发Kafka Consumer自动重试，因其通过isRetriable()识别临时故障并暂停提交offset、保持分区分配，下轮poll重新消费；永久性错误应发DLQ而非重试。
在 Kafka 消费端，若想让消费失败时触发重试（即让 Consumer 自动重新拉取同一条消息），不能靠抛出任意异常，而必须抛出 org.apache.kafka.common.errors.RetriableException 的子类（或其本身）。Kafka Consumer 会识别该异常并暂停当前 offset 提交、保持分区分配，并在下一轮 poll 中重新尝试消费该 record。
确保抛出的是真正的 RetriableException
Kafka 客户端内部通过 isRetriable() 方法判断异常是否可重试。直接 new RetriableException 不推荐（它是个抽象类），应使用其标准子类，例如：
-
NetworkException（网络临时中断） -
TimeoutException（请求超时） -
NotEnoughReplicasException（副本不足） -
UnknownServerException（服务端未知错误） - 或自定义继承
RetriableException的异常（需重写isRetriable()返回 true）
不要在业务逻辑中随意 throw RetriableException
RetriableException 应仅用于**临时性、预期会恢复的故障**，比如下游服务短暂不可用、缓存雪崩、数据库连接池耗尽等。如果是数据格式错误、主键冲突、业务校验不通过等**永久性错误**，抛 RetriableException 会导致无限重试，阻塞消费进度，甚至引发消息堆积。
建议做法：
立即学习“Java免费学习笔记（深入）”；
- 对临时故障（如 HTTP 503、Redis timeout）包装为
new TimeoutException("downstream timeout") - 对明确不可恢复的错误（如 JSON 解析失败、空字段违反业务约束），记录日志 + 跳过或发到死信 Topic，避免重试
配合 consumer 配置启用自动重试机制
仅抛异常还不够，需确认以下 consumer 配置支持重试语义：
-
enable.auto.commit=false：必须关闭自动提交，否则异常前已提交 offset，重试会丢失消息 -
max.poll.interval.ms足够大：防止处理时间稍长被踢出 Group（重试可能延长单条处理时间） - 避免在
try-catch中吞掉 RetriableException：若 catch 后没 re-throw，Consumer 就感知不到失败
示例关键代码片段：
public void consume(ConsumerRecord<String, String> record) {
try {
process(record); // 可能抛出 RetriableException 子类
} catch (TimeoutException | NetworkException e) {
// 显式抛出，让 Kafka Consumer 捕获并触发重试
throw e;
} catch (Exception e) {
// 其他非重试异常：记录 + 发送至 DLQ 或跳过
log.error("Non-retriable error on {}", record.key(), e);
sendToDlq(record, e);
}
}
注意重试边界与退避策略
Kafka Consumer 本身**不提供指数退避或最大重试次数控制**，它只是“下次 poll 再试一次”。这意味着：
- 若下游持续不可用，会高频重试（每 poll 间隔约几十毫秒到几秒），可能打垮依赖服务
- 实际项目中，建议在业务层做轻量级退避（如 Thread.sleep(100)）或使用带重试逻辑的客户端（如 Spring Kafka 的
@RetryableTopic） - Spring Kafka 3.0+ 提供
@RetryableTopic注解，可配置最大重试次数、间隔、死信路由，比手动抛 RetriableException 更可控
