Кафка проблемы с docker-compose локально - PullRequest
0 голосов
/ 05 июля 2019

Итак, я пытаюсь раскрутить свой стек JHipster с помощью поставляемого docker compose app.yaml:

version: '2'
services:
  y-app:
    image: y
    environment:
      - _JAVA_OPTIONS=-Xmx512m -Xms256m
      - SPRING_PROFILES_ACTIVE=prod,swagger
      - MANAGEMENT_METRICS_EXPORT_PROMETHEUS_ENABLED=true
      - SPRING_DATASOURCE_URL=jdbc:mysql://y-mysql:3306/y?useUnicode=true&characterEncoding=utf8&useSSL=false
      - JHIPSTER_SLEEP=30 # gives time for other services to boot before the application
      - SPRING_DATA_JEST_URI=http://y-elasticsearch:9200
      - SPRING_ELASTICSEARCH_REST_URIS=http://y-elasticsearch:9200
      - SPRING_KAFKA_CONSUMER_BOOTSTRAP_SERVERS=kafka:9092
      - SPRING_KAFKA_PRODUCER_BOOTSTRAP_SERVERS=kafka:9092
    ports:
      - 8080:8080
  y-mysql:
    extends:
      file: mysql.yml
      service: y-mysql
  y-elasticsearch:
    extends:
      file: elasticsearch.yml
      service: y-elasticsearch
  kafka:
    extends:
      file: kafka.yml
      service: kafka
    environment:
      - KAFKA_ADVERTISED_HOST_NAME=kafka
  zookeeper:
    extends:
      file: kafka.yml
      service: zookeeper

, поэтому сначала я создаю свое приложение с

./gradlew -Pprod bootJar jibDockerBuild

и затем запустил

docker-compose -f src/main/docker/app.yml up

однако я вижу следующие ошибки кафки:

[31mkafka_1 | [0m [2019-07-05 18:46:06,978] ОШИБКА [KafkaServer id = 2] Неустранимая ошибка при запуске KafkaServer.Подготовка к закрытию (kafka.server.KafkaServer) [31mkafka_1 | [0m java.lang.IllegalArgumentException: требование не выполнено: настроенные конечные точки localhost: 9092 в объявленных слушателях уже зарегистрированы посредником 0 [31mkafka_1 | [0m в scala.Predef $.require (Predef.scala: 224) [31mkafka_1 | [0m на kafka.server.KafkaServer $$ anonfun $ createBrokerInfo $ 2.apply (KafkaServer.scala: 397) [31mkafka_1 | [0 м в kafka.server.Kafroonunfo $ $$ 2.apply (KafkaServer.scala: 395) [31mkafka_1 | [0m at scala.collection.mutable.ResizableArray $ class.foreach (ResizableArray.scala: 59) [31mkafka_1 | [0 м в scala.collection.mutable.ArrayBuffer.foreach (ArrayBuffer.0 м на io.confluent.support.metrics.SupportedServerStartable.startup (SupportedServerStartable.java:114) [31mkafka_1 | [0 м на io.confluent.support.metrics.SupportedKafka.main (SupportedKafka.java:66) [31mkafka_1 | [0m [2019-07-05 18: 46: 06,992] INFO [KafkaServer id = 2] завершает работу (kafka.server.KafkaServer).

, в конце концов все приложение перестает работать:

org.springframework.context.ApplicationContextException: не удалось запустить bean-компонент 'org.springframework.kafka.config.internalKafkaListenerEndpointRegistry';Вложенное исключение - org.apache.kafka.common.errors.TimeoutException: истекло время ожидания при получении метаданных темы.

интересно, что я делаю не так, или мне нужно что-то настроить, потому что я на MacOS?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...