问题标签 [kazoo]

我刚开始使用 Kazoo，我无法运行一个非常简单的程序：

输出如下所示：

我在 Window 7 笔记本电脑上运行它，Zookeeper 服务器在 Linux 机器上运行。看起来 TCP 连接已经建立，之后很快就搞砸了。我稍微研究了一下代码。我可以看到 TCP 连接已在 connection.py:510 (self._connect(host, port)) 处建立，并且 self._socket 已分配给 create_tcp_connection(socket, *args, **kwargs) 返回的对象。但是，connectiom.py:521 处的 self.handle.select() 不喜欢套接字。任何想法？先感谢您！

我对 Erlang 很陌生，当我尝试将二进制转换为字符串时出现 badarg 错误，如下所示。

在哪里Patterns：

因为Pattern2它工作正常，但Pattern1我收到此错误，因为前缀在Pattern1.

那么，谁能告诉我如何处理前缀值可以是null或任何值的这种情况，它应该适用于这两种情况。

我正在检查 kazoo UI 平台上的代码，所以我在它的一个 js 文件中找到了这段代码，当我在线搜索有关 amplifyjs 模块时，它们不是与该主题相关的链接或内容。有人知道这到底是什么吗？

现在我想在 ZooKeeper 中获取指定 znode 的监视计数。我已阅读官方教程并知道该mntr命令。但它适用于整个 QuorumServer。

那么ZooKeeper有没有提供API来获取指定znode的watch数量呢？我也在使用kazoo，我们如何获得这些数据？

我在我正在从事的项目中使用 kazoo。但一段时间后，我收到一条错误消息，提示无法打开与 zookeper 的新连接。

所以我写了一个小测试程序：

在大约 500 次迭代之后，我遇到了一个错误：“打开的文件太多”。

我使用 kazoo 有什么问题吗？

我正在尝试使用 Zookeeper 来同步管理分布式集群。

现在我正在使用 ec2 现货实例，我希望每个 ec2 现货实例在 zookeeper 上连接并创建 znode，并带有一些元数据，如实例 ID、私有主机名、实例类型。

到目前为止，我设法让每个现场实例在 zookeeper 上创建具有各自元数据的 znode。但我想让它成为这样一种方式，即当实例（现货实例）被带走时，该 znode 将自行消失。

或者有没有更好的方法来做到这一点？

我想使用 kazoo 客户端在 Python 中节点的所有子节点上添加监视，但ChildrenWatch只监视子添加或删除，而不监视任何子节点的数据更新。我正在寻找一个简单的食谱来完成这项任务。

示例代码将是这样的

我想知道如果路径不存在，kazoo 库中是否有一种方法可以让 zookeeper 在连接字符串中创建 chroot 路径？这个事情谁有经验？我已经阅读了文档，但我还没有真正找到任何可以解决这个问题的方法。

我现在正在做的是连接到zookeeper服务器，确保路径存在，断开连接，然后重新连接路径，但这似乎不是很有效。

谢谢！

我正在使用 Kafka 和 zookeeper，并在它们之间创建连接，但是当我尝试创建新的Kafka::Consumer时连接会一次又一次地断开

我还检查了 zookeeper 和 kafka 日志文件，发现当我尝试创建新的 Kafka::Consumer 时，我的 kafka 到 zookeeper 的连接断开了

卡夫卡日志：

动物园管理员日志：

已安装的宝石

• 使用离子 1.2.3
• 使用 json 1.8.3
• 使用雷神 0.19.1
• 使用动物园管理员 1.4.11
• 使用海神 0.0.5
• 使用捆绑器 1.11.2
• 使用 cassandra-driver 2.1.5
• 使用 kazoo-ruby 0.4.0
• 使用 kafka-consumer 0.1.2

我完全不知道版本问题在哪里

得到错误：

这是kazoo readthedocs上提到的代码

要传递哪些输入参数以使特定节点成为领导者？（即 /electionpath 和 my-identifier 在这里指的是什么？）