Spring Cloud Stream多输入Topic报InvalidTopicException解决方法

报错核心原因是Spring Cloud Stream Kafka Streams Binder与Kafka客户端版本不匹配，导致多主题分隔符解析失效。从日志可以看到，程序直接把test.topic-a,test.topic-b当成单个完整主题名传给Kafka Broker，而Kafka主题名不允许包含逗号字符，因此抛出INVALID_TOPIC_EXCEPTION。
你使用的逗号分隔多主题配置是官方给出的标准写法，但该特性依赖Binder侧的字符串拆分逻辑：如果Binder版本过低，没有适配对应版本的Kafka Streams API，就不会对destination字段的逗号分隔值做拆分，直接把整个拼接字符串透传给Kafka，触发非法主题错误。单主题配置下不存在拆分逻辑，因此可以正常运行。

• 查看启动日志中实际加载的spring-cloud-stream-binder-kafka-streams版本号，确认是否为3.2.x及以上——只有3.2.x及以上版本正式兼容Kafka 3.2.x客户端，且包含Kafka Streams Binder多主题分割的稳定实现
• 将Spring Cloud Stream相关包的日志级别调整为DEBUG，搜索配置解析相关日志，确认destination字段解析后得到的主题列表是1个元素（带逗号的完整字符串，说明解析失效）还是2个元素（拆分后的两个独立主题名，说明解析正常）
• 检查项目中是否存在自定义StreamsBuilderFactoryBean的配置，确认没有覆盖Binder默认的主题解析逻辑
• 检查YAML配置中逗号前后是否存在多余空格，部分低版本Binder遇到test.topic-a, test.topic-b这类带空格的配置也会解析失败

1. 通过官方BOM统一管控依赖版本（优先推荐）
   不要单独指定kafka-clients、kafka-streams、spring-kafka的版本，避免版本错位不兼容。引入Spring Cloud和Spring Cloud Stream的官方BOM做版本仲裁，自动拉取互相兼容的依赖集：

   dependencyManagement {
       imports {
           mavenBom "org.springframework.cloud:spring-cloud-dependencies:2021.0.3"
           mavenBom "org.springframework.cloud:spring-cloud-stream-dependencies:3.2.4"
       }
   }
   

   引入BOM后，删除build.gradle中上述几个Kafka相关依赖的硬编码版本号即可。版本对齐后，原有逗号分隔的多主题配置可以正常生效。
2. 临时绕过方案（无法升级版本时使用）
   如果暂时不能升级Binder版本，放弃配置文件中多主题拼接的写法，通过代码手动指定多主题订阅：

   @Bean
   public Consumer<KStream<String, String>> process() {
       return stream -> {
           // 填写实际流处理业务逻辑
       };
   }
   
   @Bean
   public KStream<String, String> processInputStream(StreamsBuilder streamsBuilder) {
       // 手动传入多个主题名，绕过Binder的配置解析逻辑
       return streamsBuilder.stream(
           List.of("test.topic-a", "test.topic-b"),
           Consumed.with(Serdes.String(), Serdes.String())
       );
   }
   

   同时删除YAML配置中process-in-0对应的destination配置，避免重复绑定冲突。

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