сервер облачного потока данных Spring на Kubernetes

Question

Я работаю над приложением Spring Cloud Data Flow ETL Stream, у которого есть источник, который отправляет данные в сток. Приложения отлично работают в Pivotal Cloud Foundry и используют связыватель Rabbit MQ. Теперь я хочу направить этот поток на Kafka, который работает вне инфраструктуры Cloud Foundry. Итак, я явно указал URL-адрес брокера kafka в свойствах env файла конфигурации сервера потока данных, как показано ниже. Я не вижу событий в кафке. Правильная ли эта конфигурация? Я что-то упустил?

  SPRING_CLOUD_STREAM_KAFKA_BINDER_BROKERS: <kafka_server_url>:19092
  SPRING_CLOUD_STREAM_KAFKA_BINDER_ZK_NODES: <kafka_roker_url>:12181

YAML-файл конфигурации сервера Dataflow

applications:
  - name: test-scdf-server
    memory: 1G
    instances: 1
    path: ../target/scdf-server-0.0.1-SNAPSHOT.jar
    buildpacks:
    - java_buildpack
    env:
      JAVA_VERSION: 1.8.0_+
      JBP_CONFIG_SPRING_AUTO_RECONFIGURATION: '{enabled: false}'
      SPRING_CLOUD_SKIPPER_CLIENT_SERVER_URI: <skipper_server_url>
      SPRING_CLOUD_STREAM_KAFKA_BINDER_BROKERS: <kafka_server_url>:19092
      SPRING_CLOUD_STREAM_KAFKA_BINDER_ZK_NODES: <kafka_roker_url>:12181