Spring Cloud Dataflow с несколькими связями Kafka

Question

Я пытаюсь использовать Spring Cloud Dataflow для соединения двух кластеров Kafka (по сути, причудливого экземпляра MirrorMaker) с помощью приложения Bridge. Как описано в документах, я определил два связующих. Kafka-qa1 должен быть по умолчанию, а kafka-qa2 может быть предоставлен в свойствах определения или развертывания в качестве выходного связующего, например: app.bridge.spring.cloud.stream.bindings.output.binder = kafka-qa2

Мой SCDF application.yaml содержит как связующие вещества:

spring: 
    cloud: 
    dataflow: 
     applicationProperties: 
     stream: 
      spring: 
      cloud: 
       stream: 
       defaultBinder: kafka-qa1 
       binders: 
        kafka-qa1: 
        type: kafka 
        environment: 
         spring: 
         brokers: qa-1.example.com:9093 
         zk-nodes: qa-1.example.com:2181 
        kafka-qa2: 
        type: kafka 
        environment: 
         spring: 
         brokers: qa-2.example.com:9093 
         zk-nodes: qa-2.example.com:2181 

Однако, как представляется, не обращая внимания на выход связующего. Я также сохранил раздел для использования с одним связующим в моей конфигурации (ниже). Если я удалю его, опция defaultBinder, похоже, не работает, и она возвращается к localhost.

kafka: 
binder: 
    brokers: qa-1.example.com:9093 

Любые идеи или примеры, указывающие мне на подключение нескольких кластеров Kafka с помощью приложения Bridge?

Answer 1

Похоже, что токен environment отсутствует spring.cloud.stream.kafka.binder префикс для и zk-nodes. См. Ниже.

spring.cloud.dataflow.applicationProperties.stream.spring.cloud.stream.binders.kafka-qa1.type = Кафка

spring.cloud.dataflow.applicationProperties.stream.spring.cloud.stream .binders.kafka-qa1.environment. spring.cloud.stream.kafka.binder .brokers = qa-1.example.com: 9093

spring.cloud.dataflow.applicationProperties.stream.spring.cloud.stream.binders.kafka-qa1.environment , spring.cloud.stream.kafka.binder .zkNodes = qa-1.example.com: 2181

spring.cloud.dataflow.applicationProperties.stream.spring.cloud.stream.binders.kafka2.type = Кафка

spring.cloud.dataflow.applicationProperties.stream.spring.cloud.stream.binders.kafka-qa2.environment. spring.cloud.stream.kafka.binder .brokers = qa-2.example.com: 9093

spring.cloud.dataflow.applicationProperties.stream.spring.cloud.stream.binders.kafka-qa2.environment , spring.cloud.stream.kafka.binder .zkNodes = qa-2.example.com: 2181