Apache ZooKeeper是一种分布式服务，提供配置信息存储，命名，同步，协调和组服务。
Apache curator InterProcessSemaphoreMutex 版本是否会挂起？
我在代码中使用以下配方来确保单例 JVM 应用程序 公共无效acquireLock（InterProcessSemaphoreMutex锁）{ 锁.获取(); } 公共无效释放锁（
我有10个节点的kafka集群。kafka代理和zookeeper都在每个节点上运行。最近我们添加了 3 个新节点 8、9 和 10，昨天有 2 个节点关闭（2 和 4）。我有一个 60 的主题
HBase Shell - org.apache.hadoop.hbase.ipc.ServerNotRunningYetException：服务器尚未运行
我正在尝试在3个节点上设置分布式HBase。我已经设置了 hadoop、YARN ZooKeeper，现在还设置了 HBase，但是当我启动 hbase shell 并运行最简单的命令（例如状态或列表）时...
Apache Atlas：curl：无法连接到本地主机：2181。在窗户上
我有这个问题： 尽管安装了 mvn -T 4C clean -DskipTests package -Pdist,embedded-hbase-solr 但无法连接到zookeeper主机2181。 这就是问题所在： 请帮助我😢😢 帮我 阿特拉斯系列...
CMAK 哎呀！ [ActorSelection[Anchor(akka://kafka-manager-system/)] 询问超时
我正在尝试根据这篇文章在docker上实现apache kafka https://medium.com/simform-engineering/set-up-kafka-ecosystem-on-local-machine-1a00a436c0ba。 我已经更改了 yml 撰写文件...
我的消费者继承自BasicKafkaConsumerV2。在部署期间，当 Pod 旋转时，我丢失了一些消息，这些消息从手动 commit() 后打印的偏移量中可见。
我正在尝试在 Spring Boot 应用程序中设置 Kafka 生产者以将消息发送到特定主题。我收到 SerializationException。我已经检查了我的序列化器和消息的架构...
良好的 Zookeeper Hello world 程序与 Java 客户端
我尝试在我们的项目中使用Zookeeper。可以运行服务器..甚至使用 zkcli.sh 测试它..一切都好.. 但找不到一个好的教程让我使用 Java 连接到该服务器！我所有...
我正在尝试设置一个Kafka集群（实际上是集群中的第一个节点）。 我有一个单节点 Zookeeper 集群设置。 我正在一个单独的节点上设置 kafka。 两者都运行 CentOS 6.4，ru...
Kafka消费者客户端未在zookeeper上注册消费者组的偏移量
我正在尝试使用 kafka-clients v.0.10.2.1 创建具有不同消费者组的多个消费者到一个 kafka 主题。虽然我无法检索消费者组提交的最后一个偏移量...
我反复收到这些日志消息.. 12:31:39.085 [localhost-startStop-1-SendThread(localhost:2182)] 调试 org.apache.zookeeper.ClientCnxn - 获得 sessionid 的 ping 响应：0x14f7213a9400...
zookeeper 服务器到期会话超时超出（org.apache.zookeeper.server）
我是使用 Kafka 和 druid 的初学者。最近，当我在解析数据步骤将数据上传到 druid 时，出现错误。我不知道这个问题和错误。我猜想这位 Ka 动物园管理员...
我部署了一个长期运行的 Storm 拓扑。运行几个小时后，整个拓扑出现故障。我检查了工人日志，发现了这些日志。正如它所说，zookeeper 客户端会话超时并且......
需要在每个代理和控制器上运行 kafka-storage.sh
基本上就是标题。 多年来我们一直在使用 Zookeeper 运行 kafka。设置是形成 Zookeeper 集群，然后让代理连接到它。一切尽在傀儡之中。没有额外的步骤，经过一些
我入职了一家新公司，他们只有两个环境，一个是测试环境，一个是生产环境。 在测试环境中，很多开发团队都在使用这个
我正在配置三个mesos master，现在正在设置zookeeper。 动物园.cfg： server.1=cersei-master1:2888:3888 server.2=tywin-master2:2888:3888 server.3=jaime-master3:2888:3888 最大客户端Cn...
连接远程HBase实例时出现TableNotFoundException
我正在尝试连接到安装在 ubuntu 虚拟机上的远程 hbase-0.94.8。我遇到了 TableNotFoundException，这是我的 Java 代码： 配置config = HBaseConfiguration.create(); 配置.设置（“
Zookeeper Confluence Kafka 运行 Confluence 时“打开文件 Zookeeper-gc.log 时出错”
我正在 Linux 2 (WSL2) 的 Windows 子系统上构建 Kafka 应用程序。 我正在使用 Zookeeper 3.5.8、confluence-6.1.0 和 java openjdk 版本 17.0.12。 我成功安装了以上所有平台...
这是kazoo readthedocs上提到的代码 选举=zk.Election("/electionpath", "我的标识符") 要传递哪些输入参数才能使特定节点成为领导者？ （即 /
Kafka Zookeeper - Java.net.BindException：地址已在使用中
我的机器上安装了 Kafka 并且运行良好。 然后我安装了 NetBeans，我认为这把事情搞砸了。现在我的动物园管理员没有启动。 安装 netBeans 后，我遇到了错误...