Как запустить кафку в режиме мультиброкерного кластера с docker -композицией? - PullRequest
Новая
       35

Как запустить кафку в режиме мультиброкерного кластера с docker -композицией?

0 голосов
/ 02 марта 2020

У меня есть docker -compose.yml файл: 

version: '3.7'
  services:
  zookeeper-1:
  image: confluentinc/cp-zookeeper:latest
  ports:
    - 22181:22181
  environment:
  ZOOKEEPER_SERVER_ID: 1
  ZOOKEEPER_CLIENT_PORT: 22181
  ZOOKEEPER_TICK_TIME: 2000
  ZOOKEEPER_INIT_LIMIT: 5
  ZOOKEEPER_SYNC_LIMIT: 2
  ZOOKEEPER_SERVERS: zookeeper-1:22888:23888;zookeeper-2:32888:33888;zookeeper-3:42888:43888
  networks:
  - zk_net


zookeeper-2:
image: confluentinc/cp-zookeeper:latest
ports:
  - 32181:32181
environment:
  ZOOKEEPER_SERVER_ID: 2
  ZOOKEEPER_CLIENT_PORT: 32181
  ZOOKEEPER_TICK_TIME: 2000
  ZOOKEEPER_INIT_LIMIT: 5
  ZOOKEEPER_SYNC_LIMIT: 2
  ZOOKEEPER_SERVERS: zookeeper-1:22888:23888;zookeeper-2:32888:33888;zookeeper-3:42888:43888
networks:
  - zk_net

zookeeper-3:
image: confluentinc/cp-zookeeper:latest
ports:
  - 42181:42181
environment:
  ZOOKEEPER_SERVER_ID: 3
  ZOOKEEPER_CLIENT_PORT: 42181
  ZOOKEEPER_TICK_TIME: 2000
  ZOOKEEPER_INIT_LIMIT: 5
  ZOOKEEPER_SYNC_LIMIT: 2
  ZOOKEEPER_SERVERS: zookeeper-1:22888:23888;zookeeper-2:32888:33888;zookeeper-3:42888:43888
networks:
  - zk_net


kafka-1:
image: confluentinc/cp-kafka:latest
ports:
  - 19092:19092
depends_on:
  - zookeeper-1
  - zookeeper-2
  - zookeeper-3
environment:
  KAFKA_BROKER_ID: 1
  KAFKA_ZOOKEEPER_CONNECT: zookeeper-1:22181,zookeeper-2:32181,zookeeper-3:42181
  KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka-1:19092
  KAFKA_SOCKET_REQUEST_MAX_BYTES: 500000000
networks:
  - zk_net

kafka-2:
image: confluentinc/cp-kafka:latest
ports:
  - 29092:29092
depends_on:
  - zookeeper-1
  - zookeeper-2
  - zookeeper-3
environment:
  KAFKA_BROKER_ID: 2
  KAFKA_ZOOKEEPER_CONNECT: zookeeper-1:22181,zookeeper-2:32181,zookeeper-3:42181
  KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka-2:29092
  KAFKA_SOCKET_REQUEST_MAX_BYTES: 500000000
networks:
  - zk_net

kafka-3:
image: confluentinc/cp-kafka:latest
ports:
  - 39092:39092
depends_on:
  - zookeeper-1
  - zookeeper-2
  - zookeeper-3
environment:
  KAFKA_BROKER_ID: 3
  KAFKA_ZOOKEEPER_CONNECT: zookeeper-1:22181,zookeeper-2:32181,zookeeper-3:42181
  KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka-3:39092
  KAFKA_SOCKET_REQUEST_MAX_BYTES: 500000000
networks:
  zk_net:
   driver: bridge

Когда я пытаюсь убить узел-1 в docker и получить количество узлов из моего Java -кода следующим образом:

DescribeClusterResult describeClusterResult = adminClient.describeCluster(new DescribeClusterOptions()); List<Node> nodeList = new ArrayList<>(describeClusterResult.nodes().get(TIME_OUT, TimeUnit.MILLISECONDS));

Существует нулевое количество узлов, поскольку узел-1 не работает. Но я подумал, что если узел-1 не работает, то есть узел-2 и узел-3 живы, поэтому он должен работать и возвращать 2 живых узла, но это не так.

1 Ответ

0 голосов
/ 05 марта 2020

Если было бы полезно узнать, с какими свойствами вы создаете AdminClient, и если вы передаете все серверы bootstrap.

...