apache-zookeeper相关内容
我编写了一个非常基本的 Spring Boot 2 应用程序,它连接到 Zookeeper 以进行服务发现(通过使用 spring-cloud-starter-zookeeper-discovery). 应用程序在 /services/example-service 注册,值如下: {"name":"example-service","id":"cb14ad15-4d33-4f1c-a42
..
我们有一个配置良好的zookeeper和kafka集群节点.创建主题并发送关于该主题的消息的手动测试成功通过.但是当我从测试设备运行测试以使用 MQTT 协议创建主题时,我收到: 由于 java.io.IOException 导致会话 0x0 关闭的异常:Len 错误 271056900[myid:1] - INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2
..
我正在尝试在共享命名空间中将 zookeeper 和 kafka 设置为单独的 Kubernetes 部署/pod.我已经在我的 Ubuntu 沙箱上通过 kubeadm 用 Calico 引导了本地 K8s 1.8... 对于 Zookeeper,我使用了 hub.docker.com 中的图像 zookeeper:3.4,我创建了一个 Kubernetes 部署和服务,我在其中公开端口:
..
我已经编写了在没有观察者的情况下从zookeeper节点检索数据的方法.zookeeper.getData(nodePath, false, null); 上述方法调用将返回节点中的数据. 现在我想从节点获取数据,稍后当节点中发生更新时,我想要返回更新的数据. 这是与zookeeper交互的源 public class ZooKeeperOperations {公共枚举 Zoo
..
我正在尝试了解 Zookeeper 及其功能.到目前为止,我使用 Zookeeper 的经验已经通过其他需要 Zookeeper(Solr 和 Kafka)的库,所以我的基本理解是非常模糊的“你最好使用 Zookeeper 来保持你的配置正确". 请帮助我思考一个简单的示例问题.假设我构建了自己的“东西"服务.我想保护两件事: 我希望尽可能减少停机时间(必须继续做事). 我不能让一台
..
我正在尝试运行一个 TestingServer 以便能够为其编写单元测试. val zkServer = new TestingServer(2182)println(zkServer.getPort) 我的 pom 有以下与 Curator 相关的依赖,我尝试过 4.2.0 和 4.3.0 版本,都抛出相同的错误: org.apache.curator
..
我需要使用zookeeper设计分布式应用程序.这是我第一次使用 Zookeeper,所以我对它的用法有点困惑.我已经读过 Zab 协议在涉及多个更新时确保可序列化,但我无法理解,如果是这种情况,它将自动允许无锁实现.那么为什么首先需要锁呢?如果有人能在这里提供帮助,那就太好了. 谢谢 解决方案 Zab 协议是 zookeeper 的关键部分.它确保消息原子广播到副本.Zab 协议确
..
我想在钻头中为 oracle jdbc 创建存储插件.我将 ojdbc7.jar 复制到 apache-drill-1.3.0/jars/3rdparty 路径并添加 drill.exec.sys.store.provider.local.path= "/mypath" 到 dill.override.conf.当我想使用以下配置创建一个新的存储插件时: {“类型":“jdbc",“启用":真
..
我正在尝试运行 Giraph 快速入门中描述的 SimpleShortestPathsVertex(又名 SimpleShortestPathComputation)示例.我使用 VirtualBox 在 Hortonworks Sandbox 实例 (HDP 2.1) 上运行它,并使用配置文件 hadoop_2.0.0 打包了 giraph.jar. 当我尝试使用 运行示例时 hado
..
提交拓扑时的错误 java.net.ConnectException:连接被拒绝在 backtype.storm.utils.NimbusClient.(NimbusClient.java:36)在 backtype.storm.utils.NimbusClient.getConfiguredClient(NimbusClient.java:17) 这是我在 nimbus 日志文件中得到的
..
设置 1: 操作系统:Windows 10 动物园管理员 从 Apache 下载的 3 ZooKeeper 实例(使用 v3.5.6 和 v.3.4.14 测试): (1) apache-zookeeper-3.5.6-bin_1 (2) apache-zookeeper-3.5.6-bin_2 (1 的副本) (3) apache-zookeeper-3.5.6-bin_3
..
在生产环境中,是否应该在所有可能的服务器上设置 Solr,包括具有 Zookeeper 的服务器?谈外部 Zookeeper 服务器总数:5 案例 1:Solr 在所有 5 个服务器上.3台服务器上的Zookeeper. 案例2:Solr 在 2 个服务器上.3台服务器上的Zookeeper. 案例3:Solr 在 5 个服务器上.5台服务器上的Zookeeper. 最佳实践
..
目前我在测试系统中使用了一个独立的 ZK 实例.但是这个测试系统已经变成了生产系统,我想在不影响 ZK 监管的 SolrCloud 系统的可用性的情况下从 1 个 ZK 实例升级到 3 个. 从我读过的内容来看,使用滚动重启从 3 升级到 5 等等非常容易,但没有找到任何关于从独立(1 个实例)升级到 3 的信息. 有没有人对此有任何见解(任何可能尝试过的人)?谢谢! 解决方案
..
我们刚刚从 CDH 5.3.6 升级到 5.10.0,并且在尝试写入 Kafka 主题时开始出现错误.我们对一切都有默认设置,没有启用 SSL 或 Kerberos 身份验证.当使用控制台生产者写入我的主题之一时,我收到此错误: /usr/bin/kafka-console-producer --broker-list=myhost1.dev.com:9092,myhost2.dev.com
..
我有 3 个安装了 Kafka 的节点.所有这 3 个节点都有自己的 zookeeper 实例.需要 3 个 zookeeper 实例还是 1 个 zookeeper 实例就足够了?我们是否应该有多个 Zookeeper 实例来实现容错?在这种情况下,其中一个实例会作为主实例,其他实例会是副本吗? 解决方案 我不确定“所有这 3 个节点都有自己的zookeeper 实例"是什么意思基本上你
..
假设我们有一个 Apache Zookeeper 仲裁启动并运行,并且连接了 n 个客户端节点(使用 Apache Curator).当任何其他节点会话终止或达到超时时,是否可以从 Zookeeper 中的一个节点(我们正在观察的节点)接收通知?如果是这样,这是如何实现的? 解决方案 答案相当简单,可以使用 Ephemeral 节点和 PathChildrenCache 来完成.Zooke
..
有没有办法在 JVM 中强制/重现 FullGC x 秒?基本上我需要这个来验证某些基于心跳的应用程序(zookeeper 的客户端)中问题的根本原因 EDIT:是否 unix 命令 kill -STOP 和 kill -CONT 模拟 FullGC(停止世界行为)? 解决方案 您可以在 HotSpot JVM 上模拟一个很长的 stop-the-world 事件,从用户的角度来看类
..
我是 hadoop、hdfs 的新手.我已经完成了接下来的步骤: 我已经在三个namenodes中启动了zookeeper: *vagrant@172:~$ zkServer.sh start 我可以看到状态: *vagrant@172:~$ zkServer.sh 状态 结果状态: 默认启用JMX使用配置:/opt/zookeeper-3.4.6/bin/../conf/zoo.
..
如果我有集群托管 1 个具有三个分区的主题.所以 ZooKeeper(ZK) 集群托管了 3 个代理实例. 根据我的理解, Producer 将与 ZooKeeper 交互以在 Broker 上发布消息. ZK 将根据每个代理实例的负载在内部决定它需要哪个分区发布消息.Broker 也会和 ZK 互动维护每个消费者实例的偏移量 同样,Consumer 将与 ZooKeeper 交互
..
根据文档 CuratorFramework 实例是完全线程安全的.你应该分享一个应用程序中每个 ZooKeeper 集群的 CuratorFramework. 它还指出应该在执行任何其他操作之前调用方法 start.这个方法应该在每次操作前调用还是初始化后调用一次就够了? 解决方案 在创建 CuratorFramework 实例后调用 start 一次.所以,启动是: 通
..