Docker 部署的一个问题，求大神解惑

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

Docker Engine Quickstart

Boot2docker

这是一个创建于 2097 天前的主题，其中的信息可能已经有所发展或是发生改变。

问题是这样的，

我在服务器上跑了一个 Kafka，是跑的 wurstmeister/kafka 镜像，使用的默认网络。配置：

kafka: image: wurstmeister/kafka container_name: kafka environment: - KAFKA_ADVERTISED_PORT=port - KAFKA_ADVERTISED_HOST_NAME=公网 ip - KAFKA_ZOOKEEPER_COnNECT=本机内网 ip:zookeeper port - KAFKA_LOG_RETENTION_HOURS=4 - KAFKA_LOG_RETENTION_BYTES=1000000000 ports: - port:9092

然后在同一台服务器，使用 docker run 命令，启动了另外一个容器，使用的是 node-alpine 镜像，内部通过 kafka-node 库连接 kafka，怎么都连不上。

启动 node 容器后，进入容器，telnet 命令可以连上 Kafka 容器的端口。

在本机，不在容器内部，同一个连接（公网 ip：port ）可以正常连上 Kafka。

我在本机装了 Conduktor 这个 Kafka 客户端，也能连上 Kafka，可以正常收发消息。

有什么思路吗？谢谢！

启动 kafka，然后启动 node，看 node 镜像的日志就会卡住。然后 stop Kafka，node 这边就会报错：

events.js:174 throw er; // Unhandled 'error' event ^ NestedError: refreshBrokerMetadata failed at async.waterfall (/app/node_modules/daoqun-core/node_modules/kafka-node/lib/kafkaClient.js:378:35) at /app/node_modules/daoqun-core/node_modules/kafka-node/node_modules/async/dist/async.js:473:16 at next (/app/node_modules/daoqun-core/node_modules/kafka-node/node_modules/async/dist/async.js:5329:29) at /app/node_modules/daoqun-core/node_modules/kafka-node/node_modules/async/dist/async.js:969:16 at KafkaClient.getAvailableBroker (/app/node_modules/daoqun-core/node_modules/kafka-node/lib/kafkaClient.js:330:12) at async.waterfall.callback (/app/node_modules/daoqun-core/node_modules/kafka-node/lib/kafkaClient.js:373:23) at nextTask (/app/node_modules/daoqun-core/node_modules/kafka-node/node_modules/async/dist/async.js:5324:14) at Object.waterfall (/app/node_modules/daoqun-core/node_modules/kafka-node/node_modules/async/dist/async.js:5334:5) at KafkaClient.refreshBrokerMetadata (/app/node_modules/daoqun-core/node_modules/kafka-node/lib/kafkaClient.js:372:9) at Immediate._onImmediate (/app/node_modules/daoqun-core/node_modules/kafka-node/lib/kafkaClient.js:782:20) at runCallback (timers.js:705:18) at tryOnImmediate (timers.js:676:5) at processImmediate (timers.js:658:5) Caused By: Error: Unable to find available brokers to try at KafkaClient.getAvailableBroker (/app/node_modules/daoqun-core/node_modules/kafka-node/lib/kafkaClient.js:330:21) at async.waterfall.callback (/app/node_modules/daoqun-core/node_modules/kafka-node/lib/kafkaClient.js:373:23) at nextTask (/app/node_modules/daoqun-core/node_modules/kafka-node/node_modules/async/dist/async.js:5324:14) at Object.waterfall (/app/node_modules/daoqun-core/node_modules/kafka-node/node_modules/async/dist/async.js:5334:5) at KafkaClient.refreshBrokerMetadata (/app/node_modules/daoqun-core/node_modules/kafka-node/lib/kafkaClient.js:372:9) at Immediate._onImmediate (/app/node_modules/daoqun-core/node_modules/kafka-node/lib/kafkaClient.js:782:20) at runCallback (timers.js:705:18) at tryOnImmediate (timers.js:676:5) at processImmediate (timers.js:658:5) Emitted 'error' event at: at KafkaClient.<anonymous> (/app/node_modules/daoqun-core/node_modules/kafka-node/lib/baseProducer.js:101:10) at KafkaClient.emit (events.js:198:13) at async.waterfall (/app/node_modules/daoqun-core/node_modules/kafka-node/lib/kafkaClient.js:378:21) at /app/node_modules/daoqun-core/node_modules/kafka-node/node_modules/async/dist/async.js:473:16 [... lines matching original stack trace ...] at KafkaClient.refreshBrokerMetadata (/app/node_modules/daoqun-core/node_modules/kafka-node/lib/kafkaClient.js:372:9) at Immediate.<anonymous> (/app/node_modules/daoqun-core/node_modules/kafka-node/lib/kafkaClient.js:782:20) at runCallback (timers.js:705:18) at tryOnImmediate (timers.js:676:5) at processImmediate (timers.js:658:5)

Kafka

容器

port

Docker

7 条回复 2020-01-15 18:15:48 +08:00

Xbluer

2020-01-12 16:46:08 +08:00

docker run 启动 node-alpine 的时候添加这个参数 --link=kafka

Maco

2020-01-12 17:07:38 +08:00

把 Kafka 和 node 写在一个 docker-compose 中，使用一个网络，node 连接使用 container_name: kafka+端口连接。

Maco

2020-01-12 17:09:06 +08:00

根据你的描述，最大的可能就是 node 和 kafka 不在一个网络中

ilaipi

2020-01-12 17:09:13 +08:00

@Xbluer #1 谢谢~我试了加了 link，启动命令改成：
docker run --env-file .env --env NODE_REPO=mr -p 11111:11111 -dit --restart always --name=mr_dev --link=kafka:kafka --net middleware_default mr:0.0.1

然后连接地址是 kafka:9092

还是一样的反应。我进入 node 容器，telnet kafka 9092 也是能通..

无奈了

ilaipi

2020-01-12 19:05:57 +08:00

@Maco #3 我也怀疑是网络问题，但是明明在 node 容器里都能 telnet kafka 端口。。。搞了两天了，唉

ilaipi

2020-01-12 19:34:03 +08:00

抱歉了，程序是启动成功了。。

只是程序启动成功打的一句日志，记到日志文件里，所以 docker logs 命令看不到，我一直以为是卡住了。。。。

两天时间啊。。。

julyclyde

2020-01-15 18:15:48 +08:00

@ilaipi 你为什么不让它出错退出呢？