我试图设置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设置开发环境。
谢谢
2条答案
按热度按时间6uxekuva1#
当变量被重命名时,README的这一部分似乎没有更新(我不知道他们为什么这样做)
变量现在以
KAFKA_CFG
开头,如本页的其他部分所示,这可能解释了为什么从默认值覆盖的监听器属性不起作用。我写的这一段是正确的
注意,存储库中已经有一个集群文件-https://github.com/bitnami/bitnami-docker-kafka/blob/master/docker-compose-cluster.yml
但是,一台机器就是一个单点故障,因此在一个合成文件中包含两个代理对恢复能力或吞吐量没有帮助。
ijxebb2r2#
我认为zookeeper找不到Kafka,Kafka找不到zookeeper,因为localHost名称冲突,如果使用Ubuntu操作系统使用这种方式?如果Ubuntu,我认为您需要更改/etc/hosts中的设置主机
看这个链接http://manpages.ubuntu.com/manpages/bionic/man5/hosts.5.html
这就是解决办法