Zookeeper 使用Docker设置Kafka和zooker进行开发

ix0qys7i  于 2022-12-09  发布在  Apache
关注(0)|答案(2)|浏览(142)

我试图设置Kafka和Zookeeper的发展,我下面这个教程:

version: "3"
services:
  zookeeper:
    image: 'bitnami/zookeeper:latest'
    ports:
      - '2181:2181'
    environment:
      - ALLOW_ANONYMOUS_LOGIN=yes
  kafka-src:
    image: 'bitnami/kafka:latest'
    ports:
      - '9092:9092'
    environment:
      - KAFKA_BROKER_ID=1
      - KAFKA_LISTENERS=PLAINTEXT://:9092
      - KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:9092
      - KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
      - ALLOW_PLAINTEXT_LISTENER=yes
    depends_on:
      - zookeeper
  kafka-dst:
    image: 'bitnami/kafka:latest'
    ports:
      - '9093:9093'
    environment:
      - KAFKA_BROKER_ID=2
      - KAFKA_LISTENERS=PLAINTEXT://:9093
      - KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:9093
      - KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
      - ALLOW_PLAINTEXT_LISTENER=yes
    depends_on:
      - zookeeper

但是当我执行docker-compose up时,我得到错误Connection to node 2 (/127.0.0.1:9093) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
我的总体目标是能够为Kafka设置开发环境。
谢谢

6uxekuva

6uxekuva1#

当变量被重命名时,README的这一部分似乎没有更新(我不知道他们为什么这样做)
变量现在以KAFKA_CFG开头,如本页的其他部分所示,这可能解释了为什么从默认值覆盖的监听器属性不起作用。
我写的这一段是正确的
注意,存储库中已经有一个集群文件-https://github.com/bitnami/bitnami-docker-kafka/blob/master/docker-compose-cluster.yml
但是,一台机器就是一个单点故障,因此在一个合成文件中包含两个代理对恢复能力或吞吐量没有帮助。

ijxebb2r

ijxebb2r2#

我认为zookeeper找不到Kafka,Kafka找不到zookeeper,因为localHost名称冲突,如果使用Ubuntu操作系统使用这种方式?如果Ubuntu,我认为您需要更改/etc/hosts中的设置主机
看这个链接http://manpages.ubuntu.com/manpages/bionic/man5/hosts.5.html
这就是解决办法

[your ip Address] [local Host]
140...1           localhost
140...1           abed-Inspiron-5593
140...1           release.gitkraken.com
140...1           mysql
140...1           eurekaserver
140...1           keycloak
140...1           kafka
140...1           zookeeper

相关问题