весенний облачный поток данных на сервере kubernetes - PullRequest
Новая
       76

весенний облачный поток данных на сервере kubernetes

0 голосов
/ 25 октября 2019

Я работаю над весенним облачным потоком данных Приложение 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 конфигурации сервера потока данных 

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
...