Kafka用户无法连接到其动物园管理员
Exception in thread "main" org.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to zookeeper server within timeout: 6000
at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:880)
at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:98)
at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:84)
at kafka.consumer.ZookeeperConsumerConnector.connectZk(ZookeeperConsumerConnector.scala:171)
at kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:126)
at kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:143)
at kafka.consumer.Consumer$.create(ConsumerConnector.scala:94)
at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:145)
at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
共有1个答案
你确定zookeeper服务器可以从你有kafka的机器上访问吗？
通常zookeeper在端口2181上监听，kafka在端口9092上监听。在您的命令中，您试图在端口9092上连接到172.31.8.226上的zookeeper，这是正确的吗。
另一种解决方法是，先在zookeeper机器上运行这个命令，然后在kafka机器上运行，检查是否可以连接并试用zookeeper。
bin/zookeeper-shell.sh --zookeeper 172.31.8.226:9092
-
我试图在本地机器上以分布式模式配置Apache Drill。为此，我已经使用配置文件（这里，sagar pc解析为我的wlan0 inet addr）： Zookeeper服务成功运行，启动Apache Drill后，它能够根据文件。此外，状态检查告诉我： 钻头在运转 钻头的ZooManager输出： 文件内容： 然而，即使完成了所有这些步骤，当我试图在目录中运行命令时，它也会给我以下错误： 在Z
-
我是Kafka的新手，动物园管理员和Storm。我我们的环境，我们有一个Kafka代理连接到多个动物园管理员。让生产者将消息发送到特定主题并在一个代理上将分区到多个动物园管理员与多个代理分配给多个动物园管理员相比是否有优势？
-
假设我有 3 台 Kafka 服务器。服务器 1 zoopkeeper1 服务器 2 zoopkeeper2 服务器 3 zoopkeeper3 在集群配置中，zoopkeepers 会发生什么？它们是为每个服务器单独维护的，还是会在群集配置中同步其数据？
-
在Zookeeper和代理身份验证上启用SASL时，我面临以下错误。 以下配置在JAAS文件中给出，该文件作为KAFKA_OPTS传递，将其作为JVM参数：- Kafka经纪人的服务器。属性设置了以下额外字段：- Zookeeper属性如下所示：
-
我正在Mac（W/docker-machine）上的Docker中运行Kafka(0.10.0.0)。我从Spotify的Dockerfile中派生了我的Dockerfile，这意味着Kafka和Zookeeper在同一个图像中运行。 这将产生以下错误输出： 看起来我无法连接（大概是动物园管理员）。为什么不呢？
-
分布式 Apache HBase 安装依赖于正在运行的 ZooKeeper 集群。所有参与节点和客户端都需要能够访问正在运行的 ZooKeeper 集合。 Apache HBase 默认为您管理 ZooKeeper“集群”。它将启动和停止 ZooKeeper 集合作为 HBase 启动/停止过程的一部分。您还可以独立于 HBase 管理 ZooKeeper 集合，只需将 HBase 指向它应该使用