Can't connect Kafka to Zookeeper

Refresh

November 2018

Views

629 time

2

From docker-compose I got this yml:

version: '2'
services:
  zookeeper:
    container_name: zookeeper
    image: confluentinc/cp-zookeeper:3.1.1
    ports:
      - "2080:2080"
    environment:
      - ZOOKEEPER_CLIENT_PORT=2080
      - ZOOKEEPER_TICK_TIME=2000

  kafka:
    container_name: kafka
    image: confluentinc/cp-kafka:3.1.1
    ports:
      - "9092:9092"
    environment:
      - KAFKA_CREATE_TOPICS=Topic1:1
      - KAFKA_ZOOKEEPER_CONNECT=192.168.99.100:2080
      - KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.99.100:9092
    depends_on:
      - zookeeper

  schema-registry:
    container_name: schema-registry
    image: confluentinc/cp-schema-registry:3.1.1
    ports:
      - "8081:8081"
    environment:
      - SCHEMA_REGISTRY_KAFKASTORE_CONNECTION_URL=192.168.99.100:2080
      - SCHEMA_REGISTRY_HOST_NAME=localhost
    depends_on:
      - zookeeper
      - kafka

When I stand up this docker the console output ends with:

schema-registry | Error while running kafka-ready.
schema-registry | org.apache.kafka.common.errors.TimeoutException: Timed out waiting for Kafka to create /brokers/ids in Zookeeper. timeout (ms) = 40000
schema-registry exited with code 1

It seems like kafka never connect Zookeper or something like that, does anyone knows why this is happening?

1 answers

0

Есть ли изменения

SCHEMA_REGISTRY_KAFKASTORE_CONNECTION_URL=192.168.99.100:2080

в

SCHEMA_REGISTRY_KAFKASTORE_CONNECTION_URL=zookeeper:2080

Помогите?

Кроме того, KAFKA_ZOOKEEPER_CONNECT=192.168.99.100:2080следует отметить zookeeperтакже, вместо IP - адреса. Или, как вы можете быть уверены , что IP - адрес?

KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.99.100:9092упоминает IP - адрес , который вы не могли бы быть в состоянии гарантировать , как хорошо. Что касается последнего, то IP - адрес может быть изменен в kafka.

У меня также были проблемы в получении Кафку и Zookeeper работать в Докер (через Докер Compose). В конце концов, https://github.com/confluentinc/cp-docker-images/blob/5.0.0-post/examples/kafka-single-node/docker-compose.yml работал для меня. Вы можете использовать его в качестве источника вдохновения.