使用Docker设置kafka和zooker进行开发



我正在尝试设置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。

感谢

当变量被重命名时,README的这一部分似乎没有更新(我不知道他们为什么这么做(

变量现在以KAFKA_CFG开头,如页面的其他部分所示,这可能解释了为什么您从默认值重写的侦听器属性不起作用。

我写的这一部分是正确的

注意,repo中已经有一个集群文件-https://github.com/bitnami/bitnami-docker-kafka/blob/master/docker-compose-cluster.yml

然而,一台机器是一个故障点,因此在一个组合文件中包含两个代理对恢复能力或吞吐量没有帮助。特别是因为您没有将内部主题配置为具有多个的默认复制因子

我认为动物园管理员找不到卡夫卡,卡夫卡也找不到动物园管理员becouse 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

最新更新