Kafka消费者重试次数耗尽后，如何跳过DLQ执行自定义逻辑？

完全可以实现重试耗尽后仅执行自定义逻辑而不发送至DLQ，具体可通过以下两步修改：

1. 禁用默认DLQ策略 #

在@RetryableTopic注解中添加dltStrategy = DltStrategy.NONE配置，关闭框架自动发送DLQ的行为：

@RetryableTopic(
    attempts = "2", 
    backoff = @Backoff(delay = 3000, multiplier = 1.5, maxDelay = 15000),
    dltStrategy = DltStrategy.NONE // 禁用默认DLQ发送机制
)
@KafkaListener(topics = "my-topic")
public void consume(
    @Header(KafkaHeaders.RECEIVED_TOPIC) String receivedTopic, 
    MyEvent event) {
    // consumer logic here
    throw new RuntimeException("模拟消费失败场景");
}

2. 添加重试耗尽后的自定义处理逻辑 #

使用@Recover注解定义恢复方法，该方法会在所有重试次数耗尽后触发，你可以在其中记录自定义错误日志或执行其他业务逻辑：

@Recover
public void recover(RuntimeException e, @Header(KafkaHeaders.RECEIVED_TOPIC) String receivedTopic, MyEvent event) {
    // 自定义错误处理逻辑示例：打印错误详情
    System.err.printf("消费事件失败，已耗尽重试次数。Topic: %s, Event内容: %s, 错误原因: %s%n", 
                      receivedTopic, event.toString(), e.getMessage());
    // 也可扩展执行其他操作，比如发送报警通知、更新业务状态等
}

关键注意点 #

• 恢复方法的参数需与原消费方法匹配，同时必须包含触发重试的异常类型（如上述的RuntimeException），框架会根据异常类型匹配对应的恢复方法。
• 若需针对不同异常做差异化处理，可定义多个带@Recover注解的方法，分别对应不同异常类型。

内容的提问来源于stack exchange，提问作者Vin