容器之间的通信连接失败

Question

CONTAINER ID        IMAGE               COMMAND                  CREATED             STATUS              PORTS                                            NAMES
23dbed8536dc        dc62102ccd75        "/opt/startkafka.sh"     4 minutes ago       Up 4 minutes                                                         inspiring_nobel
8f89ce6a4b57        00088267fb34        "/opt/startzookeeper…"   7 minutes ago       Up 7 minutes        2888/tcp, 192.168.1.5:2181->2181/tcp, 3888/tcp   vigorous_zhukovsky

zookeeper_connect=localhost:2181

当我码头工人运行Kafka集装箱

[2018-07-15 01:31:58,369]信息打开到服务器本地主机/127.0.0.1:2181的套接字连接。将不尝试使用SASL（未知错误）（org.apache.zookeeper.clientcnxn）[2018-07-15 01:31:58,373]警告会话0x0服务器为空，意外错误，关闭套接字连接并试图重新连接（org.apache.zookeeper.clientcnxn）java.net.connectException：在sun.nio.ch.socketchannelimpl.checkconnect（本机方法）在sun.nio.ch.socketchannelimpl.finishconnect（socketchannelimpl.java：717）在.java:361)位于org.apache.zookeeper.clientcnxn$sendthread.run(Clientcnxn.java:1141)[2018-07-15 01:31:59,479]打开到服务器本地主机/127.0.0.1:2181的套接字连接的信息。将不尝试使用SASL（未知错误）（org.apache.zookeeper.clientcnxn）[2018-07-15 01:31:59,481]警告会话0x0服务器为空，意外错误，关闭套接字连接并试图重新连接（org.apache.zookeeper.clientcnxn）java.net.connectException：在sun.nio.ch.socketchannelimpl.checkconnect（本机方法）在sun.nio.ch.socketchannelimpl.finishconnect（socketchannelimpl.java：717）在.java:361)位于org.apache.zookeeper.clientcnxn$sendthread.run（clientcnxn.java:1141)

我知道kafka容器无法连接到zookeeper更改kafka配置zookeeper_connect=192.168.1.5:2181

[2018-07-15 01:35:40,833]建立到192.168.1.5/192.168.1.5:2181的信息套接字连接，启动会话(org.apache.zookeeper.clientcnxn)[2018-07-15 01:35:40,836]信息无法从服务器sessionid 0x0读取其他数据，可能服务器已关闭套接字，正在关闭套接字连接并试图重新连接(org.apache.zookeeper.clientcnxn)[2018-07-15 01:35:42,520]错误KafkaServer启动期间出现致命错误。准备关闭（kafka.server.kafkaserver）kafka.zookeeper.zookeePerClientTimeoutException：处于状态时等待连接超时：在kafka.zookeePer.zookeePer.zookeePerClient$$anonFun$kafka$zookeePerClient$$zookeePerClient$$waitintilConnected$1.在kafka.zookeePer.zookeePerClient.zookeePerClient$$waitintilConnected$1处应用ZookeePerClient$$AnonFun$Kafka$ZookeeperClient$$WaitIntilConnected$1.应用(ZookeePerClient.Scala:221)在Kafka.utils.coreutils.inlock(COREUTILS.Scala:250)在Kafka.ZookeePer.ZookeePerClient.Kafka$ZookeePerClient.Kafka$ZookeePerClient.Scala:221)在Kafka.ZookeePerClient.Scala:221)在38）在kafka.server.kafkaserver.kafka$server$kafkaserver$$CreatezkClient$1(kafkaserver.scala:345)在kafka.server.kafkaserver.initzkClient(kafkaserver.scala:369）在kafka.server.kafkaserver.startup(kafkaserver.scala:202)在kafka.server.kafkaserverstarttable.startup(kafkaserverstarttable.scala:38)在kafka.kafka$.main(kafka.scala.main(kafka.scala:92)在kafka.kafka.scala)[2018-07-15 01:35:42,523]信息关闭(kafka.server.kafkaserver[2018-07-15 01:35:42,525]ka.server.kafkaserver$$anonfun$shutdown$5.在kafka.utils.coreutils$.scala:569)在kafka.server.kafkaserver.shutdown(kafkaserver.scala:85)在kafka.server.kafkaserver.startup(kafkaserver.scala:569)在kafka.server.kafkaserver.startup(kafkaserver.scala:326)在kafka.server.kafkaserver.scala:38)在afka.main(kafka.scala)[2018-07-15 01:35:42,528]信息关闭完成(kafka.server.kafkaserver)[2018-07-15 01:35:42,528]退出Kafka时出错。(kafka.server.kafkaserverstartable)[2018-07-15 01:35:42,530]信息关闭(kafka.server.kafkaserver）

我不知道如何让kafka容器连接到zookeeper容器，或者测试容器之间的连接性。谢谢你的任何建议！

Answer 1

与本例一样，每个kafka节点应该在运行时（在docker运行时）引用zookpeepr集群节点的IP：

docker run -p 9092:9092 \
  -e ZOOKEEPER_CONNECT=10.0.0.1:2181,10.0.0.2:2181,10.0.0.3:2181 \
  -e KAFKA_HOST=host_kafka1 -e KAFKA_PORT=9092 -e BROKER_ID=0 \
  --name kafka1 jeygeethan/kafka-cluster

大意在此表达：

另外，如果您有一个名为ZK-01的外部zookeeper服务器，那么您还需要传递zookeeper.connect

docker run --tty --interactive --rm \
  --name kafka-01 \
  --publish 9092:9092 \
  --env SERVER__ZOOKEEPER_CONNECT=zk-01 \  <=============
  --env SERVER__BROKER_ID=1 \
  --env SERVER__COMPRESSION_TYPE=gzip \
  --link zk-01 \
  christiangda/kafka bin/kafka-server-start.sh config/server.properties