Докер Kafka - ОШИБКА: «Невозможно найти лидера для раздела 0» - PullRequest
Новая
       13

Докер Kafka - ОШИБКА: «Невозможно найти лидера для раздела 0»

0 голосов
/ 25 декабря 2018


Ниже приведена часть моего файла YML для zookeeper и Kafka Dockers
Я добавил переменную "KAFKA_CREATE_TOPICS", чтобы создавать темы при запуске, но для создания всех 6 тем требуется много времени.поэтому каждый раз, когда я поднимаю докеры вверх и вниз, мне нужно подождать, пока все созданные темы
* решение для создания тем kafkaProducer мне не подходит

когда kafka / zookeeper подняты, я хочу ихчтобы запомнить все темы, я добавил тома в Zookeeper, он работал и теперь тема существует при запуске, но я не могу использовать ни одну тему, потому что получаю следующую ОШИБКУ:
"Невозможно найти лидера для раздела 0" 

      zoo1:
    image: xx.xx.xx.xx:5002/zookeeper
    hostname: zoo1
    ports:
      - 2181:2181
    environment:
      ZOO_MY_ID: 1
      ZOO_SERVERS: server.1=zoo1:2888:3888 server.2=zoo2:2888:3888 server.3=zoo3:2888:3888
    networks:
      - xxnet  
    deploy:
      restart_policy:
        condition:  on-failure 
    logging:
      driver: json-file
      options:
        max-size: 50m 
    volumes:    
      - /home/docker-volumes/zoo1-conf/:/conf
      - /home/docker-volumes/zoo1-data/:/data
      - /home/docker-volumes/zoo1-datalog/:/datalog


  kafka:
    image: xx.xx.xx.xx:5002/wurstmeister/kafka
    ports:
      - 9092:9092

    environment:
        KAFKA_ZOOKEEPER_CONNECT: zoo1:2181
        KAFKA_ADVERTISED_HOST_NAME: xx.xx.xx.xx
        KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092
        KAFKA_ZOOKEEPER_CONNECTION_TIMEOUT_MS: 1600000
        #KAFKA_AUTO_CREATE_TOPICS_ENABLE=true
        KAFKA_LOG_RETENTION_HOURS: 0
        KAFKA_LOG_RETENTION_MINUTES: 0
        KAFKA_LOG_RETENTION_MS: 120000
        RETENTION.MS: 900000
        ADVERTISED_HOST: kafkaserver
        ADVERTISED_PORT: 9092
        KAFKA_SEGMENT_BYTES: 1073741824
        KAFKA_RETENTION_CHECK_INTERVAL_MS: 300000
        KAFKA_CREATE_TOPICS: topic1:1:1,topic2:1:1,topic3:1:1,topic4:1:1,topic5:1:1,topic6:1:1


    networks:
      - xxnet   
    volumes: 
     - /var/run/docker.sock:/var/run/docker.sock 
     - /home/docker-volumes/kafka-logs/:/tmp/kafka-logs
     - /home/docker-volumes/kafka-logs/kafka:/kafka
    deploy:
      restart_policy:
        condition:  on-failure     
    logging:
      driver: json-file
      options:
        max-size: 50m

Спасибо, Ларри

...