Spring Cloud Stream多Kafka Topic消费遇异常及后续问题求助

问题根源 #

• 初始配置里指定了group.instance.id（静态消费者标识），Spring Cloud Stream默认会为每个Topic创建独立的消费者实例，导致同一个instance.id对应多个不同的member.id，触发Kafka的FencedInstanceIdException。
• 加了consumer.multiplex=true后，因为destination用了逗号分隔的字符串格式，绑定器错误地把"topic-a,topic-b"当成单个Topic名称发给Broker，所以引发InvalidTopicException。

正确配置方案 #

把destination改成YAML数组格式，搭配multiplex=true，让单个消费者同时订阅多个Topic，既解决instance.id冲突，又避免Topic名称解析错误：

spring:
  cloud:
    function:
      definition: app
    stream:
      bindings:
        app-in-0:
          destination: 
            - topic-a
            - topic-b
          group: mygroup
          consumer:
            multiplex: true
      kafka:
        binder:
          consumer-properties:
            group:
              instance:
                id: myid

原理说明 #

• multiplex=true的作用是让绑定器用单个消费者实例订阅多个Topic，但必须保证destination是数组形式，不能是逗号分隔的字符串，否则绑定器没法正确拆分Topic列表。
• 用数组格式的destination后，单个消费者实例会同时订阅topic-a和topic-b，这时group.instance.id只对应一个member.id，符合Kafka静态消费者的要求，彻底解决FencedInstanceIdException。

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