我已经创建了一个多容器应用程序,其中只有一个容器无法连接到Kafka (名为“后端”的容器引发错误"kafka.errors.NoBrokersAvailable: NoBrokersAvailable")。最奇怪的是,名为"apigateway“的容器使用相同的变量连接Kafka,效果很好。不同之处在于,我在"apigateway“中使用了kafka-python,而在”后端“中使用了。
但是,当我在码头外运行“后端”容器时--使用“码头运行”,而不是连接到码头桥,而是连接到主机上的容器,一切都很好。我在下面使用的命令:
docker run --env KAFKA_HOST=localhost --env KAFKA_PORT=9092 --env DATA_REQUEST_TOPIC=data-request-topic --env DB_TYPE='mongodb' --env DB_USERNAME='root' --env DB_PASSWORD='root' --env DB_HOST=localhost --env DB_PORT=27017 --env DB_NAME='backend_microservice_database' --env DB_COLLECTION='ms_collection' --net=host -it backend_microservice:latest我的码头-下面是:
version: '2.1'
services:
zookeeper:
image: confluentinc/cp-zookeeper:latest
ports:
- "2181:2181"
environment:
ZOOKEEPER_CLIENT_PORT: 2181
# reachable on 9092 from the host and on 29092 from inside docker compose
kafka:
image: confluentinc/cp-kafka:6.2.4
depends_on:
- zookeeper
ports:
- '9092:9092'
expose:
- '29092'
environment:
KAFKA_ZOOKEEPER_CONNECT: 'zookeeper:2181'
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:29092,PLAINTEXT_HOST://localhost:9092
KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: '1'
KAFKA_MIN_INSYNC_REPLICAS: '1'
init-kafka:
image: confluentinc/cp-kafka:6.2.4
depends_on:
- kafka
entrypoint: [ '/bin/sh', '-c' ]
command: |
"
# blocks until kafka is reachable
kafka-topics --bootstrap-server kafka:29092 --list
echo -e 'Creating kafka topics'
kafka-topics --bootstrap-server kafka:29092 --create --if-not-exists --topic data-request-topic --replication-factor 1 --partitions 1
kafka-topics --bootstrap-server kafka:29092 --create --if-not-exists --topic data-response-topic --replication-factor 1 --partitions 1
kafka-topics --bootstrap-server kafka:29092 --create --if-not-exists --topic order_topic --replication-factor 1 --partitions 1
echo -e 'Successfully created the following topics:'
kafka-topics --bootstrap-server kafka:29092 --list"
apigateway:
image: diploma_gateway:latest
depends_on:
- kafka
ports:
- "5000:5000"
expose:
- '5000'
environment:
KAFKA_HOST: kafka
KAFKA_PORT: 29092
DATA_REQUEST_TOPIC: data-request-topic
ALLOWED_OUTER_HOSTS: 0.0.0.0
mongodb:
image: mongo:5.0.8
ports:
- 27017:27017
expose:
- 27017
volumes:
- ./database_storage:/data/db
environment:
- MONGO_INITDB_DATABASE=backend_microservice_database
- MONGO_INITDB_ROOT_USERNAME=root
- MONGO_INITDB_ROOT_PASSWORD=root
backend:
image: backend_microservice:latest
restart: always
network_mode: "bridge"
depends_on:
- mongodb
- kafka
environment:
KAFKA_HOST: kafka
KAFKA_PORT: 29092
DATA_REQUEST_TOPIC: data-request-topic
DB_TYPE: mongodb
DB_USERNAME: root
DB_PASSWORD: root
DB_HOST: mongodb
DB_PORT: 27017
DB_NAME: backend_microservice_database
DB_COLLECTION: ms_collection有人能告诉我我做错了什么吗?
发布于 2022-05-04 06:48:58
我不能告诉你到底出了什么问题,但这里有一些想法:
depends_on只表示服务和开始/停止顺序之间的依赖关系。但撰写并不是在等待服务准备就绪。解决这一问题的可能性有两种:
restart: always,它必须确保它不会挂在某处等待。在编写时不需要expose端口,通常它们必须在Dockerfile中定义
删除network_mode: "bridge",如果您完全不声明,compose将在默认情况下创建一个桥接网络,并且所有服务都将加入它。
卡夫卡需要知道允许的听众:
KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:29092,PLAINTEXT_HOST://127.0.0.1:9092https://stackoverflow.com/questions/72106765
复制相似问题