Spring Cloud Stream Kinesis绑定器消费者重试配置不生效问题

1. Kinesis Binder 2.2.0 对重试配置的支持 #

你的技术栈版本完全匹配：Spring Cloud 2021.0.6（Jubilee）、Spring Boot 2.7.10、Kinesis Binder 2.2.0，这个版本的Kinesis Binder完全支持你配置的重试参数，包括退避初始间隔、最大间隔、乘数和最大重试次数，不用怀疑版本兼容性问题。

2. AWS部署后重试不触发的排查点和解决办法 #

（1）自定义错误处理器覆盖了重试逻辑 #

你配置了error-handler-definition: myDefaultErrorHandler，如果这个自定义错误处理器没正确集成重试机制，会直接导致重试不触发：

• 若使用SeekToCurrentErrorHandler，必须将其与符合你配置的RetryTemplate绑定；
• 若无特殊需求，直接删除该错误处理器配置即可——默认处理器会自动读取你配置的重试参数，无需额外编码。

正确的自定义错误处理器示例：

@Bean
public ErrorHandler myDefaultErrorHandler(RetryTemplate retryTemplate) {
    return new SeekToCurrentErrorHandler(retryTemplate);
}

@Bean
public RetryTemplate retryTemplate() {
    RetryTemplate retryTemplate = new RetryTemplate();
    // 匹配配置中的max-attempts:3
    SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
    retryPolicy.setMaxAttempts(3);
    retryTemplate.setRetryPolicy(retryPolicy);
    
    // 匹配退避策略参数
    ExponentialBackOffPolicy backOffPolicy = new ExponentialBackOffPolicy();
    backOffPolicy.setInitialInterval(1000);
    backOffPolicy.setMaxInterval(10000);
    backOffPolicy.setMultiplier(2.0);
    retryTemplate.setBackOffPolicy(backOffPolicy);
    
    return retryTemplate;
}

（2）异常类型不在默认重试范围内 #

默认情况下，重试仅针对RuntimeException触发。如果你的业务异常是受检异常（Checked Exception），需要手动配置标记其为可重试：

spring:
  cloud:
    stream:
      bindings:
        personEvent-in-0:
          consumer:
            retryable-exceptions:
              # 替换为你的异常类全路径
              com.yourcompany.YourBusinessException: true

（3）日志级别不足导致看不到重试记录 #

将应用日志级别调整为DEBUG或INFO，重试过程会输出类似RetryContext retrieved: count=1的日志，可通过日志确认重试是否实际执行。

（4）偏移量自动提交配置异常 #

Kinesis Binder默认在消息处理成功后才提交分片迭代器（等价于偏移量），若误开启auto-commit-offset=true，失败消息会被直接跳过不重试。检查该配置是否被修改为true，默认值应为false。

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