问题标签 [kazoo]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
python - 如何使用 kazoo 在 zookeeper 节点上停止 datawatch？
如何使用 python 模块 kazoo 显式停止在 zNode 上启动的 datawatch 进程？以下是我创建数据观察的方式
我浏览了kazoo wiki并想出了以下方法。
- 从传递的回调方法返回 False（此处为 callback_function）将停止 zNode 上的数据监视。但这种方式不适合我，因为 callback_function 由用户处理而不是在我手中。
- 当进程停止时，datawatch 会自动被杀死。但我不想停止这个过程。
这是我目前使用的 hacky 方式。datawatch 类下有一个私有成员变量“_stopped”。我将其设置为 true。
/li>
有人可以在这里提出更好的解决方案。谢谢。
python - 所有可能的时间“kazoo.exceptions.ConnectionLoss”被提出？
我正在使用apache-zookeeper和kazoo framework满足我的要求之一。我有一个简单的 Zookeeper 集群设置，并且很少有客户端连接到服务器集群以读取节点信息。我kazoo.exceptions.ConnectionLoss随机面对（五十次一次）。我关心的是什么时候提出这个例外？以下是我认为的要点。
- 与服务器的连接丢失
- 服务器在服务器配置中设置的超时时间内没有响应
这个例外还有其他原因吗？我没有看到文档对此进行详细解释。
jython - 使用 Jython 的 Kazoo 包
Kazoo 在 Python 下运行良好，但我正在处理的项目需要在 Jython 下使用它。
这是问题：
我已经说过了 - 使用 python 没有这种问题。我很确定它与 _socket.py 文件的 Jython 版本连接，但不知道解决方法。
你能推荐什么？
python - kazoo重启zookeeper，手表抛出异常
我的配置：
动物园管理员：3.4.10
操作系统：ubuntu 16.04
蟒蛇：2.7
卡祖笛：2.3.1
我在 IPython 中运行的代码：
当我重新启动 zookeeper 时bin/zkServer.sh restart，shell 显示如下异常：
如果我删除手表并替换为侦听器，则侦听器运行良好。
我不知道为什么，我从谷歌和 github/kazoo 阅读了信息，但我没有找到关于如何解决问题的解释。
PS：有人说因为客户端连接的session过期丢失了，所以zookeeper重启时session_id和重试连接不一样
python - 引发异常时，kazoo DataWatch 不会退出程序
我正在使用 kazoo=2.2.1、python 2.7、zookeeper 3.4.5--1。我已经设置了一个 DataWatch，如果回调引发异常，我想中止程序。我无法使用以下代码中止
`
我如何中止wrap_do_stuff()？
python - 用于管理 kafka 集群的 python 库（主题 CRUD、增加分区、重新分配、领导选举等）
我在互联网上搜索了 python 库来管理 kafka 操作，例如主题上的 CRUD、分区增量、分区重新分配、领导者选举等。我没有找到任何东西。
我知道 pykafka、kafka-python，但它们用于创建消费者/生产者，我可以使用 kazoo 对主题进行 CRUD，但我无法执行我提到的其他操作。你能推荐任何用于管理 kafka 集群的 python 库（如果有的话）吗？
谢谢！
erl - 安装 kazoo 2600hz 后在哪里可以找到 *.erl 文件
安装 kazoo 2600hz 后我在哪里可以在我的服务器上找到或开发 *.erl 文件我看不到任何 .erl 文件！
我正确安装了 kazoo 并且它可以工作，但是我找不到要开发的文件这是关于权限的吗？
python - 使用凭据通过 kazoo lib 连接到 Zookeeper
我正在尝试使用凭据保护我的动物园管理员。
到目前为止，我已经使用以下代码连接到 zookeeper：
现在，为了添加凭据，我添加了一个带有addauth digest username:password命令的身份验证并将 ACL 设置为带有setAcl /znode auth:username:password:crdwa.
现在，当我尝试通过 zkCli 连接到 Zookeeper 服务器时，我得到了
kazoo.exceptions.NoAuthError
作为例外。
但是我如何将身份验证凭据传递给KazooClient？
我可以使用创建 ACL 凭据
并添加default_acl，auth_data例如
但我仍然无法通过 python 连接。
我应该如何通过 kazoo 客户端对 zookeeper 服务器进行身份验证？
谢谢
python - 使用 python kazoo 客户端的 Zookeeper 服务器健康检查/监控
我有一个 python 脚本来监控 Zookeeper 服务器的健康检查 - 基本上检查 Zookeeper 是否启动并运行。每分钟运行一次。
所以我刚刚写了一个简单的python方法，它将创建一个新的zookeeper kazoo客户端，然后启动和停止客户端。
这是正确的方法吗？显然，它在我的本地环境中运行良好，但考虑到当它进入实时生产环境时，考虑到其他 Zookeeper 客户端也将主动连接到同一个 Zookeeper 服务器，它不应该导致一些性能问题或破坏其他任何东西。