无法连接到远程动物园管理员

srn*_*srn 5 ubuntu networking apache-kafka apache-zookeeper

我正在尝试设置一个带有单个zookeeper实例的kafka集群,该实例运行在与kafka服务器不同的机器上。

我可以从同一台计算机连接到我的 ZooKeeper 实例(通过在该计算机上创建 kafka 服务器),但我无法从本地网络中的计算机连接其他 kafka 服务器。

所有服务器都在私有云中运行,默认情况下所有端口都是开放的。我能够 ping 和 telnet 到机器,但我似乎无法到达 ZooKeeper 实例:

# On the ZooKeeper machine
> telnet 10.155.208.82 2181
Trying 10.155.208.82...
Connected to 10.155.208.82.

# On any other machine
> telnet 10.155.208.82 22
Trying 10.155.208.82...
Connected to 10.155.208.82.

> telnet 10.155.208.82 2181
Trying 10.155.208.82...
# Nothing happens ...
Run Code Online (Sandbox Code Playgroud)

超过连接到 ZooKeeper 的超时后,Kafka 出错:

[2015-12-28 18:52:21,632] INFO Initiating client connection, connectString=10.155.208.82:2181 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@43ee72e6 (org.apache.zookeeper.ZooKeeper) [2015-12-28 18:52:21,645] INFO Opening socket connection to server 10.155.208.82/10.155.208.82:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) [2015-12-28 18:52:21,650] INFO Waiting for keeper state SyncConnected (org.I0Itec.zkclient.ZkClient) [2015-12-28 18:52:27,651] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread) [2015-12-28 18:52:27,758] INFO Session: 0x0 closed (org.apache.zookeeper.ZooKeeper) [2015-12-28 18:52:27,759] INFO EventThread shut down (org.apache.zookeeper.ClientCnxn) [2015-12-28 18:52:27,760] FATAL Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) org.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to zookeeper server within timeout: 6000 at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1223) at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:155) at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:129) at kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:89) at kafka.utils.ZkUtils$.apply(ZkUtils.scala:71) at kafka.server.KafkaServer.initZk(KafkaServer.scala:278) at kafka.server.KafkaServer.startup(KafkaServer.scala:168) at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:37) at kafka.Kafka$.main(Kafka.scala:67) at kafka.Kafka.main(Kafka.scala) [2015-12-28 18:52:27,764] INFO shutting down (kafka.server.KafkaServer) [2015-12-28 18:52:27,770] INFO shut down completed (kafka.server.KafkaServer) [2015-12-28 18:52:27,771] FATAL Fatal error during KafkaServerStartable startup. Prepare to shutdown (kafka.server.KafkaServerStartable)

我究竟做错了什么?如果有帮助的话,说明虚拟机在私有云中没有分配任何主机名。