spring-kafka消费者错误处理场景下重试次数配置不生效问题

排查与修复方案 #

• 自定义监听器容器工厂冲突
  你在@KafkaListener中指定了自定义的messageKafkaListenerContainerFactory，如果该工厂内部手动配置了SeekToCurrentErrorHandler等全局错误处理器，会覆盖@RetryableTopic自动注入的重试转发逻辑，导致消息一直走默认的无限重试规则，不会转发到重试主题或DLT。
  修复方式：移除自定义容器工厂中配置的全局错误处理器，@RetryableTopic会为标注的监听器自动适配专用的错误处理逻辑。
• attempts参数语义配置错误
  @RetryableTopic的attempts参数统计的是包含首次消费在内的总尝试次数，你当前配置值为"1"，意味着首次消费失败就直接进入DLT，不会执行重试。如果需要1次重试，需要将值改为"2"（首次消费+1次重试）。
• 重试/DLT主题未提前创建
  你配置了autoCreateTopics = "false"，框架不会自动生成重试主题和DLT主题。如果未手动提前创建对应主题，消息无法转发到重试/DLT队列，就会一直在主topic循环投递。
  修复方式：手动创建对应主题，命名规则为<主topic名称>-retry-<索引>、<主topic名称>-dlt，分区数和副本数建议和主topic保持一致。
• Spring Kafka版本不兼容
  @RetryableTopic是Spring Kafka 2.7版本之后新增的特性，如果你使用的版本低于2.7.0，该注解会直接失效，走默认的重试逻辑。
  修复方式：升级Spring Kafka版本到2.7.0及以上。
• 异常匹配规则过滤
  检查@RetryableTopic的include/exclude参数是否配置了异常过滤规则，你抛出的RuntimeException如果未被包含在重试异常范围内，也会导致重试逻辑失效。

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