我有一个kafka 0.10.1.0集群(2个节点)和一个动物园管理员3.4.6 (3个节点)我还尝试了一系列其他别名,包括服务的DNS名称和Zookeeper的负载均衡器,所有这些都是我独立确认工作的。<init>(StaticHostProvider.java:61)
at org.apache.zookee
我是Apache和Vagrant的新手,我想将我的拓扑部署到使用Vagrant构建的虚拟集群上。(DelegatingMethodAccessorImpl.java:43)at clojure.lang.Reflector.invokeMatchingMethod[INFO] Opening socket connection to server zookeeper/192.168.50.3
我正在配置一个由3个经纪人组成的Kafka集群。集群使用了一个由3个节点组成的动物园管理员集群。之后,我可以停止节点(例如,停靠器停止zoo1),并且我仍然可以从集群中的任何其他节点查询znode。 at org.apache.zookeeper.ZooKeeper.<init>(ZooKeeper.ja
我正在创建一个3节点Zookeeper集群和一个3节点Kafka集群。当我创建Zookeeper集群时,只创建了其中一个zookeeper节点,而对于其他两个节点中的每个节点,其他两个节点退出时都会出现以下错误:zookeeper-3_1 | at sun.nio.ch.Net.bind(Net.java:425)
<
我使用卡夫卡,动物园管理员和卡夫卡-经理来管理集群。现在,当我要删除一个主题时,它会显示以下错误。(KeeperException.java:119) ~[org.apache.zookeeper.zookeeper-3.4.6.jar:3.4.6-1569965]
at org.apache.zookeeper.KeeperException.crea