我正在尝试设置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
然而,一台机器是一个故障点,因此在一个组合文件中包含两个代理对恢复能力或吞吐量没有帮助。特别是因为您没有将内部主题配置为具有多个的默认复制因子
查看此链接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