我正在使用zooKeeper编写一个领导者选举算法。我能够编写领导者选举部分。但我需要所有的节点,在一个路径中,接收节点添加/删除的事件,到那个特定的路径。
举个例子,假设我有几个节点在<代码>/选举 中。当其他一些节点被添加到相同的路径中,或者从路径中删除时,我需要接收到该路径中所有现有节点的此事件。我能够观看单个节点。但是如何观看路径中的所有节点。
此外,我还需要接收所有节点的领导者更改事件。有没有办法实现这一点?
使用Apache Curator API(正如评论建议的那样-我同意已经实现了-谢谢Netflix!)...
http://curator.apache.org/curator-recipes/node-cache.html
该应用编程接口允许通过注册侦听器来监视“ZNode”以获取值更新以及删除/更改事件。
分布式 Apache HBase 安装依赖于正在运行的 ZooKeeper 集群。所有参与节点和客户端都需要能够访问正在运行的 ZooKeeper 集合。 Apache HBase 默认为您管理 ZooKeeper“集群”。它将启动和停止 ZooKeeper 集合作为 HBase 启动/停止过程的一部分。您还可以独立于 HBase 管理 ZooKeeper 集合,只需将 HBase 指向它应该使用
我正在为Storm开发代码,这是开发人员的一个示例。我的问题是,当您从IDE Eclipse运行此代码时,不会建立Storm和ZooKeer之间的连接。ZooKeer在2181中运行,也设置在storm.yaml. 我的例外是: 有什么想法或程序要执行吗?是否从配置代码中传递?和我一样?
为什么在kafka-consumer中不推荐使用zookeeper,为什么推荐使用bootstrap服务器?引导服务器的优势是什么?
这看起来是个不错的资源。但是我甚至不能成功地运行官方的领事docker映像(在服务器或代理模式下)。我可以让这个工作(这里用)。但如果可能的话,我想用官方形象。 有没有人拿到过与Kafka和动物园管理员一起工作的官方领事形象? A)首先,我想让它在docker-compose中工作。这是我的docker-compose.yml文件,我试图让Kafka使用Consul来发现Zookeeper节点。
我已经设置了一个带有SASL SCRAM安全性的Kafka集群,它运行良好。 根据文档,我使用了命令< code>kafka-configs.sh来创建用户名和密码,并授予该用户对主题的访问权限。 这也很棒。 但是, 命令本身不需要任何类型的身份验证,因此在我看来,任何人都可以运行该命令并在Kafka中创建自己的用户并授予自己的权限。 也许我需要在Zookeeper上启用SASL安全性?但我找不到
假设我有 3 台 Kafka 服务器。服务器 1 zoopkeeper1 服务器 2 zoopkeeper2 服务器 3 zoopkeeper3 在集群配置中,zoopkeepers 会发生什么?它们是为每个服务器单独维护的,还是会在群集配置中同步其数据?