Spring Boot集成Amazon Kinesis消费流名称配置不生效问题

针对你遇到的流名称配置未生效、应用默认使用kinesisConsumer-in-o而非指定的test-test.tst.v1的问题，可从以下几个方向排查和解决：

1. 确认绑定配置的层级与通道名匹配 #

Spring Cloud Stream函数式模型中，函数的输入通道名默认格式为{函数名}-in-0。如果你定义的函数是kinesisConsumer，那么默认输入通道是kinesisConsumer-in-0，而非手动指定的input-in-0（除非额外配置通道映射）。

确保你的application.yml配置层级正确，且通道名与函数对应：

spring:
  cloud:
    stream:
      # 指定要启用的函数
      function:
        definition: kinesisConsumer
      bindings:
        # 通道名必须匹配函数的默认输入通道：kinesisConsumer-in-0
        kinesisConsumer-in-0:
          destination: test-test.tst.v1

如果一定要使用input-in-0作为通道名，需额外配置函数与通道的映射：

spring:
  cloud:
    stream:
      function:
        definition: kinesisConsumer
      bindings:
        input-in-0:
          destination: test-test.tst.v1
          group: kinesisConsumer-group
      function:
        bindings:
          kinesisConsumer-in-0: input-in-0

2. 检查是否存在配置覆盖 #

排查是否有全局或绑定级别的Kinesis配置覆盖了destination设置：

• 检查spring.cloud.stream.kinesis.bindings.{channel-name}.consumer.stream是否被手动设置为其他值，这个配置会直接覆盖destination的流名称。
• 确认全局provisioner配置未强制指定流名，比如spring.cloud.stream.kinesis.binder.provisioning下的相关配置。

3. 验证配置加载有效性 #

启动应用时开启DEBUG日志，搜索spring.cloud.stream.bindings相关条目，确认kinesisConsumer-in-0（或input-in-0）的destination值是否被正确加载为test-test.tst.v1。如果日志中显示配置值未正确读取，需检查配置文件路径、格式是否正确，或是否有其他配置文件（如application.properties）覆盖了yml配置。

4. 清理构建缓存 #

IDE或构建工具（Maven/Gradle）的缓存可能导致配置未更新，尝试执行以下操作：

• 清理Maven缓存：mvn clean install
• 清理Gradle缓存：./gradlew clean build
• 重启IDE并刷新项目配置

5. 确认流名称合法性 #

虽然你的流名test-test.tst.v1符合Kinesis的命名规则（支持字母、数字、连字符、点号，长度1-128），但仍可确认该流已在AWS Kinesis中创建，避免因流不存在导致provisioner生成默认流名。

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