apache-zookeeper相关内容
我想同时使用 confluent/kafka 和 confluent/zookeeper 并在单个 Ubuntu 服务器上运行它们. 我正在使用以下配置: docker run -e ZOOKEEPER_CLIENT_PORT=2181 --name zookeeper confluent/zookeeper docker run --name kafka -e KAFKA_AD
..
我在 OpenShift/Kubernetes 环境中运行 Zookeeper.我已将 zookeeper 设置为 StatefulSet 以可靠地保留配置数据. 我在 zoo.cfg 中按主机名配置了三个服务器,但在启动时,主机名解析失败.我在我的集群中使用 nslookup 验证了主机名确实可以解析. zoo.cfg: clientPort=2181dataDir=/var/
..
我在试图弄清楚我的选择是什么时感到迷茫.Apache 的程序员指南和管理员指南没有详细说明任何实质性内容.我的 O'Reilly Zookeeper 书几乎没有谈到安全性……我错过了什么吗?我希望通过 google 找到有关验证客户端连接、授权操作以及加密 Zookeeper 和客户端之间发送的消息的教程. 解决方案 我遇到了很多麻烦,但我想通了,底部的链接对我有很大帮助. 这段代码
..
我有两个问题,我找不到任何流行/广泛接受的解决方案: 使用 Java 程序启动 zookeeper 服务器的最简单方法是什么? 而且,是否可以将服务器添加到 zookeeper 集群,而无需手动转到每台机器并使用新节点的 id 和 ip:port 条目更新其配置文件? 有人可以帮忙吗?谢谢! 解决方案 如果你想从你的 Java 代码启动一个新的 ZooKeeper 服务器
..
所以今天我们遇到了一个令人不安的 solr 问题.在整个集群重新启动后,分片之一将停止索引/存储文档.直到我们开始编制索引(查询服务器看起来不错)之前,我们才对这个问题有所暗示.错误是: 2014-05-19 18:36:20,707 ERROR o.a.s.u.p.DistributedUpdateProcessor [qtp406017988-19] ClusterState 说我们是领导者
..
我使用 node-zookeeper-client 作为 java 脚本作为动物园管理员客户端. 我有这样的事情: const setWatch = (path, functionToExecuteOnTrigger) =>{client.getData(path, (event) => {//这里设置观察者functionToExecuteOnTrigger(event);}, 空值)/
..
我正在设置一个风暴集群来计算实时趋势和其他统计数据,但是我在将“恢复"功能引入该项目时遇到了一些问题,因为它允许 kafka-spout 最后读取的偏移量(kafka-spout 的源代码来自https://github.com/apache/incubator-storm/tree/master/external/storm-kafka)被记住.我以这种方式启动我的 kafka-spout:
..
我在单节点中使用 zookeeper 3.4.8 并尝试使用 kafka. 当我运行这个命令时: zookeeper-server-start.sh/usr/local/kafka_2.9.2-0.8.2.2/config/zookeeper.properties 我收到以下错误: [2016-02-22 17:32:41,661] ERROR 意外异常,异常退出 (org.apach
..
Apache Curator 锁配方(或较低级别的 ZooKeeper)中是否有任何工具可用于自动释放超过某个 TTL 的锁?如果没有,是否有处理该问题的最佳做法?我看到 Curator 会在客户端连接丢失的情况下自动释放锁,这很好……而且锁获取超时也很有帮助. 我想知道我需要在多大程度上保护我的系统,通过重复性的工作来寻找已经存在很长时间的锁并手动释放它们.我可以通过让我的单独进程直接删除
..
如何在 Zoo Keeper 中更新 SolrCloud 的现有配置文件? 我使用的是带有 ZooKeeper 3.3.6 的 Solr4 Beta 版本.我更新了一个配置文件,并重新启动了将配置文件上传到 ZooKeeper 的 Solr 实例.但是当我从 SolrCloud 管理控制台检查配置文件时,我没有看到更新.我无法理解这是否是 SolrCloud 管理控制台的问题,或者我是否无法
..
我是 Zookeeper 的新手,安装和运行它是一个真正的问题.我不确定这里有什么问题,但我会解释我正在做什么以使其更清楚: 1.- 我遵循了 Apache 提供的安装指南.这意味着下载 Zookeeper 发行版(稳定版)解压缩文件并移动到主目录. 2.- 因为我使用的是 Ubuntu 12.04,所以我修改了 .bashrc 文件,包括: export ZOOKEEPER_INS
..
我正在学习 Zookeeper,到目前为止我不明白将其用于数据库无法解决的分布式系统的目的. 我读过的用例是通过让 Zookeeper 客户端读/写 Zookeeper 服务器来为分布式系统实现锁、屏障等.不能通过读/写数据库来实现吗? 例如,我的书描述了使用 Zookeeper 实现锁的方法是让想要获取锁的 Zookeeper 客户端创建一个 ephemeral znode,并在 l
..
我的法定人数中有三台服务器.他们正在运行 ZooKeeper 3.4.5.根据 mntr 的输出,其中两个似乎运行良好.其中一个在几天前由于部署而重新启动,此后一直无法加入法定人数.日志中突出的一些行是: 2014-03-03 18:44:40,995 [myid:1] - INFO [main:QuorumPeer@429] - currentEpoch 未找到!使用合理的默认值 0 创建.这
..
由于尝试启动 Zookeeper 实例时出现故障,我无法运行 Apache Kafka 服务.我已经在官方网站上下载并试用了所有 3 个可用的下载.(二进制文件和源代码)当我尝试使用 启动 zookeeper 时 ./bin/zookeeper-server-start.sh config/zookeeper.properties 我总是收到相同的错误消息: 类路径为空.请先构建项目,
..
有一些关于 Solr 认证 & 的主题和文章.授权,但我无法让它工作(我喜欢的方式). 我遵循了这些教程/信息来源:https://cwiki.apache.org/confluence/display/solr/Authentication+and+Authorization+Plugins和https://lucidworks.com/blog/2015/08/17/securing-s
..
我正在尝试使用 Accumulo 连接到 VM.问题是,我无法将它连接到 Java.我可以看到 Apache 抛出的网页,但我无法让它与代码一起工作.我认为这是一个缺乏知识的问题,而不是一个真正的问题,但我找不到关于它的文档.所有示例都使用 localhost 作为 zooServer 名称,这显然对我不起作用. 所以,这是我的代码: String instanceName = "acc
..
我有 3 个节点(nodes0、node1、node2)Kafka 集群(broker0、broker1、broker2),复制因子为 2,Zookeeper(使用与 Kafka tar 一起打包的 zookeeper)在不同的节点(节点 4)上运行. 我在启动 zookper 和剩余节点后启动了代理 0.在 broker 0 日志中可以看到它正在读取 __consumer_offsets
..
我使用以下方法创建了一个 znode: zookeeper-0:/opt/zookeeper/bin # ./zkCli.sh create/mynode content digest:user:pass:cdrwa 现在如何使用 zkCli.sh 工具访问 znode? zookeeper-0:/opt/zookeeper/bin # ./zkCli.sh get/mynode连接到本地主
..
我现在使用 CDH-5.3.1 集群,其中三个 Zookeeper 实例位于三个 ip: 133.0.127.40 n1133.0.127.42 n2133.0.127.44 n3 启动时一切正常,但最近我注意到节点 n2 不断收到警告: 捕获流异常结束EndOfStreamException: 无法从客户端 sessionid **0x0** 读取附加数据,可能客户端已关闭套接字在 org
..
我想使用Kafka 10.2自带的内嵌Zookeeper 3.4.9,不单独安装Zookeeper.每个 Kafka 代理在本地主机上总是有一个 1:1 的 Zookeeper. 因此,如果我在主机 A、b、C、D 和 E 上有 5 个代理,每个代理都运行一个 Kafka 和 Zookeeper 实例,那么仅运行 Kafka 提供的 Zookeeper 就足够了吗? 与独立版本相比,嵌
..