spring cloud 多重绑定在 3.2.2 jar 中不起作用

Question

我正在尝试使用 Avro 输入消息将 json(topic-json) 和 avro(topic-avro) 消息发送到多个主题。当我将“binder”设置为值（即binder：kafka-1-with-ssl）时，出现 application.yaml 错误。我还使用下面的 jars：

"org.springframework.cloud:spring-cloud-stream-binder-kafka-streams",-->3.2.2
"org.springframework.cloud:spring-cloud-stream-binder-kafka",-->3.2.2

dependencyManagement {
    imports {
        mavenBom "org.springframework.cloud:spring-cloud-dependencies:2021.0.1"
    }
}

我不确定我在下面的 yaml 文件中做错了什么。

spring:
  cloud:
    stream:
      function:
        definition: processor
      bindings:
        processor-in-0:
          content-type: application/json
          destination: input-topic-in-avro
          consumer:
            use-native-decoding: true
        processor-out-0:
          binder: kafka-1-with-ssl
          destination: topic-json
          content-type: application/json
          producer:
            use-native-encoding: true
            key-serializer: org.apache.kafka.common.serialization.Serdes$StringSerde
            value-serializer: org.springframework.kafka.support.serializer.JsonSerde
        error-out-0:
          binder: kafka-2-with-ssl
          destination: topic-avro
          content-type: application/json
          producer:
            use-native-encoding: true
            key-serializer: org.apache.kafka.common.serialization.StringSerializer
            value-serializer: io.confluent.kafka.serializers.KafkaAvroSerializer
      binders:
        kafka-1-with-ssl:
          type: kafka
          environment:
            spring.cloud.stream.kafka.binder:
              auto-create-topics: false
              brokers: <broker-name>
              configuration: # Common properties for SSL...
              producer-properties:
                key.serializer: org.apache.kafka.common.serialization.StringSerializer
                value.serializer: org.springframework.kafka.support.serializer.JsonSerializer
        kafka-2-with-ssl:
          type: kafka
          environment:
            spring:
              cloud:
                stream:
                  kafka:
                    binder:
                      auto-create-topics: false
                      brokers: <broker-name>
                      configuration: # Common properties for SSL...
                      producer-properties:
                        key.serializer: org.apache.kafka.common.serialization.StringSerializer
                        value.serializer: io.confluent.kafka.serializers.KafkaAvroSerializer
                        schema.registry.url: <registry-url>

先感谢您。