Spring Cloud Stream AWS Kinesis Binder不支持部分消费者属性的问询

我们在测试Spring Cloud Stream微服务时发现：流处理过程中抛出异常时，Spring Cloud Stream Binder for AWS Kinesis完全不执行重试逻辑，不遵循以下消费者配置；但相同配置下，Spring Cloud Stream Kafka Binder会正常触发消费者重试。

配置内容如下：

spring:
  cloud:
    stream:
      bindings:
        bindingName:
          binder: kinesis
          consumer:
            back-off-initial-interval: 1000
            back-off-max-interval: 1000
            back-off-multiplier: 2.0
            max-attempts: 5

请问：

• Spring Cloud Stream Binder for AWS Kinesis不支持这些通用消费者属性的原因是什么？
• 该Binder是否有计划实现这些重试配置？

原因说明 #

Spring Cloud Stream的各个Binder实现并非完全统一所有通用属性，Kinesis Binder的设计逻辑和Kafka Binder存在差异：

• Kinesis本身的消费模型基于分片迭代器和checkpoint机制，默认情况下，当消费者抛出异常时，Kinesis Binder不会自动重试，而是依赖于失败记录的重新处理（比如通过死信队列或手动重置分片迭代器）。
• 通用的max-attempts、back-off-*等重试属性是Kafka Binder基于自身消费模型实现的逻辑，Kinesis Binder目前并未适配这些属性，因为其原生的消费重试机制需要结合Kinesis的特性来设计，而非直接复用通用配置。

实现计划 #

目前Spring Cloud Stream Kinesis Binder的官方路线中，已经有计划逐步对齐更多通用的Spring Cloud Stream消费者属性，包括重试相关配置。不过具体的实现时间线需要结合社区贡献和优先级来确定，你可以关注项目的issue和里程碑来跟踪进度。

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