apache-zookeeper相关内容

Zookeeper 错误:由于 java.io.IOException 导致会话 0x0 关闭的异常:Len 错误

我们有一个配置良好的zookeeper和kafka集群节点.创建主题并发送关于该主题的消息的手动测试成功通过.但是当我从测试设备运行测试以使用 MQTT 协议创建主题时,我收到: 由于 java.io.IOException 导致会话 0x0 关闭的异常:Len 错误 271056900[myid:1] - INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2 ..
发布时间:2021-11-15 00:07:54 其他开发

Kubernetes 服务与 kafka 无法按预期工作

我正在尝试在共享命名空间中将 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 ..
发布时间:2021-11-15 00:07:48 其他开发

学习 Zookeeper - 帮我举例

我正在尝试了解 Zookeeper 及其功能.到目前为止,我使用 Zookeeper 的经验已经通过其他需要 Zookeeper(Solr 和 Kafka)的库,所以我的基本理解是非常模糊的“你最好使用 Zookeeper 来保持你的配置正确". 请帮助我思考一个简单的示例问题.假设我构建了自己的“东西"服务.我想保护两件事: 我希望尽可能减少停机时间(必须继续做事). 我不能让一台 ..
发布时间:2021-11-15 00:07:45 其他开发

使用 Zookeeper 的分布式应用程序

我需要使用zookeeper设计分布式应用程序.这是我第一次使用 Zookeeper,所以我对它的用法有点困惑.我已经读过 Zab 协议在涉及多个更新时确保可序列化,但我无法理解,如果是这种情况,它将自动允许无锁实现.那么为什么首先需要锁呢?如果有人能在这里提供帮助,那就太好了. 谢谢 解决方案 Zab 协议是 zookeeper 的关键部分.它确保消息原子广播到副本.Zab 协议确 ..

Solr 和 Zookeeper 配置

在生产环境中,是否应该在所有可能的服务器上设置 Solr,包括具有 Zookeeper 的服务器?谈外部 Zookeeper 服务器总数:5 案例 1:Solr 在所有 5 个服务器上.3台服务器上的Zookeeper. 案例2:Solr 在 2 个服务器上.3台服务器上的Zookeeper. 案例3:Solr 在 5 个服务器上.5台服务器上的Zookeeper. 最佳实践 ..
发布时间:2021-11-15 00:07:21 其他开发

Zookeeper - 从独立升级到法定人数

目前我在测试系统中使用了一个独立的 ZK 实例.但是这个测试系统已经变成了生产系统,我想在不影响 ZK 监管的 SolrCloud 系统的可用性的情况下从 1 个 ZK 实例升级到 3 个. 从我读过的内容来看,使用滚动重启从 3 升级到 5 等等非常容易,但没有找到任何关于从独立(1 个实例)升级到 3 的信息. 有没有人对此有任何见解(任何可能尝试过的人)?谢谢! 解决方案 ..
发布时间:2021-11-15 00:07:17 服务器开发

Cloudera 上的 Kafka - test=TOPIC_AUTHORIZATION_FAILED

我们刚刚从 CDH 5.3.6 升级到 5.10.0,并且在尝试写入 Kafka 主题时开始出现错误.我们对一切都有默认设置,没有启用 SSL 或 Kerberos 身份验证.当使用控制台生产者写入我的主题之一时,我收到此错误: /usr/bin/kafka-console-producer --broker-list=myhost1.dev.com:9092,myhost2.dev.com ..

Kafka 中的 Zoopekeeper 实例

我有 3 个安装了 Kafka 的节点.所有这 3 个节点都有自己的 zookeeper 实例.需要 3 个 zookeeper 实例还是 1 个 zookeeper 实例就足够了?我们是否应该有多个 Zookeeper 实例来实现容错?在这种情况下,其中一个实例会作为主实例,其他实例会是副本吗? 解决方案 我不确定“所有这 3 个节点都有自己的zookeeper 实例"是什么意思基本上你 ..
发布时间:2021-11-15 00:07:10 其他开发

如何检测 Apache Zookeeper 会话何时丢失或超时?

假设我们有一个 Apache Zookeeper 仲裁启动并运行,并且连接了 n 个客户端节点(使用 Apache Curator).当任何其他节点会话终止或达到超时时,是否可以从 Zookeeper 中的一个节点(我们正在观察的节点)接收通知?如果是这样,这是如何实现的? 解决方案 答案相当简单,可以使用 Ephemeral 节点和 PathChildrenCache 来完成.Zooke ..
发布时间:2021-11-15 00:07:07 Java开发

如何在 JVM 中强制/重现 FullGC?

有没有办法在 JVM 中强制/重现 FullGC x 秒?基本上我需要这个来验证某些基于心跳的应用程序(zookeeper 的客户端)中问题的根本原因 EDIT:是否 unix 命令 kill -STOP 和 kill -CONT 模拟 FullGC(停止世界行为)? 解决方案 您可以在 HotSpot JVM 上模拟一个很长的 stop-the-world 事件,从用户的角度来看类 ..
发布时间:2021-11-15 00:07:04 Java开发

ZooKeeper 在集群中的作用?

如果我有集群托管 1 个具有三个分区的主题.所以 ZooKeeper(ZK) 集群托管了 3 个代理实例. 根据我的理解, Producer 将与 ZooKeeper 交互以在 Broker 上发布消息. ZK 将根据每个代理实例的负载在内部决定它需要哪个分区发布消息.Broker 也会和 ZK 互动维护每个消费者实例的偏移量 同样,Consumer 将与 ZooKeeper 交互 ..
发布时间:2021-11-15 00:06:58 Java开发

应该在 CuratorFramework 的方法启动和关闭时调用?

根据文档 CuratorFramework 实例是完全线程安全的.你应该分享一个应用程序中每个 ZooKeeper 集群的 CuratorFramework. 它还指出应该在执行任何其他操作之前调用方法 start.这个方法应该在每次操作前调用还是初始化后调用一次就够了? 解决方案 在创建 CuratorFramework 实例后调用 start 一次.所以,启动是: 通 ..
发布时间:2021-11-15 00:06:53 Java开发