SeekToCurrentErrorHandler不执行重试及转DLT问题求助（旧版Spring Kafka）

针对你遇到的SeekToCurrentErrorHandler不按配置重试、不触发DLT的问题，结合旧版Spring Kafka（2.2~2.7版本，尚未引入DefaultErrorHandler）的特性，给出以下排查和修复方案：

1. 修正重试次数参数的理解错误 #

SeekToCurrentErrorHandler的第二个构造参数maxFailures指的是允许的总失败次数（包含第一次调用），而非重试次数。例如：

• 若需要重试3次，应设置maxFailures = 4（1次正常调用 + 3次重试）
• 若你当前的maxRetryCount是重试次数，必须加1后传入构造器

修正后的代码：

@Bean
public SeekToCurrentErrorHandler errorHandler(DeadLetterPublishingRecoverer recoverer) {
    // maxRetryCount是期望的重试次数，总失败次数=重试次数+1
    int maxFailures = Math.toIntExact(maxRetryCount) + 1;
    return new SeekToCurrentErrorHandler(recoverer, maxFailures);
}

2. 确保DeadLetterPublishingRecoverer配置正确 #

你的代码中仅传入了recoverer，但recoverer必须依赖ProducerFactory才能发送DLT消息。需正确配置recoverer的Bean：

@Bean
public DeadLetterPublishingRecoverer deadLetterPublishingRecoverer(ProducerFactory<String, Object> producerFactory) {
    // 默认规则：DLT主题为原主题+"-dlt"，分区与原消息一致
    return new DeadLetterPublishingRecoverer(producerFactory);
    
    // 若需自定义DLT主题规则，可添加TopicPartitionResolver：
    // return new DeadLetterPublishingRecoverer(producerFactory,
    //     (record, ex) -> new TopicPartition(record.topic() + "-custom-dlt", record.partition()));
}

如果recoverer未正确注入ProducerFactory，将无法发送DLT消息。

3. 检查消费者核心配置 #

• 禁用自动提交偏移量：确保消费者配置中enable.auto.commit = false（Spring Kafka默认值为false，若手动修改过需改回）。开启自动提交会导致Seek操作失效，重试时直接跳过消息。
• 避免手动提交偏移量：若监听器使用@KafkaListener并设置了ackMode=MANUAL/MANUAL_IMMEDIATE，需确保不在代码中手动调用Acknowledgment.acknowledge()，否则会导致偏移量被提交，无法触发重试。

4. 自定义异常重试规则（可选） #

SeekToCurrentErrorHandler默认仅对可重试异常（如RetriableException）进行重试，若你的业务异常属于非可重试类型，会直接触发DLT。如需让所有异常都参与重试，可添加异常分类器：

@Bean
public SeekToCurrentErrorHandler errorHandler(DeadLetterPublishingRecoverer recoverer) {
    int maxFailures = Math.toIntExact(maxRetryCount) + 1;
    SeekToCurrentErrorHandler handler = new SeekToCurrentErrorHandler(recoverer, maxFailures);
    // 设置所有异常都允许重试
    handler.setClassifier(throwable -> true);
    return handler;
}

5. 改用RetryTemplate实现更灵活的重试控制（推荐） #

从Spring Kafka 2.3版本开始，SeekToCurrentErrorHandler支持传入RetryTemplate，可更精准控制重试次数、退避策略等：

@Bean
public SeekToCurrentErrorHandler errorHandler(DeadLetterPublishingRecoverer recoverer) {
    RetryTemplate retryTemplate = new RetryTemplate();
    // 设置总尝试次数（含第一次调用）=重试次数+1
    SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
    retryPolicy.setMaxAttempts(Math.toIntExact(maxRetryCount) + 1);
    retryTemplate.setRetryPolicy(retryPolicy);
    
    // 添加退避策略（可选，避免短时间内频繁重试）
    FixedBackOffPolicy backOffPolicy = new FixedBackOffPolicy();
    backOffPolicy.setBackOffPeriod(1000); // 每次重试间隔1秒
    retryTemplate.setBackOffPolicy(backOffPolicy);
    
    return new SeekToCurrentErrorHandler(recoverer, retryTemplate);
}

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