Apache ZooKeeper是一种分布式服务,提供配置信息存储,命名,同步,协调和组服务。
在最后一天左右的时间里,我尝试使用融合的 docker 镜像在本地设置一个节点的 Kafka 集群。不幸的是,一直未能做到这一点。以下是我的所有配置文件: /etc/卡夫卡/
我正在运行 ZooKeeper 最新稳定版本 3.8.4。我将其安装在 /usr/local/zookeeper/ 并配置 /usr/local/zookeeper/conf/zoo.cfg 来指定 数据目录=/var/zookeeper 日志配置...
HBase 连接在 INFO Zookeeper 处挂起。ClientCnxn:服务器上的会话建立完成。如何进一步连接?
我根本无法将我的客户端计算机连接到 HBase。 客户端在 Windows 8 上运行。HBase 在 Fedora VM 上运行。 我导入了以下罐子: 公共配置(commons-configuration-1.6.jar) 公共资源-
Zookeeper$Status 中的 isAlive() 和 isConnected() 有什么区别? (3.4.5)
这是源代码,让我困惑的是状态“close”和“not_connected”。(zookeeper版本r3.4.5) 公共枚举状态{ 连接、关联、连接、连接READO...
我已将spark配置为使用zookeeper作为RECOVERYMODE以实现高可用性。我们需要在 Zookeeper 上启用具有身份验证的 ACL。我还配置了spark来传递zookeeper客户端
在 Windows 上运行 Kafka 但出现日志文件夹访问被拒绝的异常
我一直在尝试在本地Windows计算机上运行zookeeper和kafka 2.13。我已经修改了服务器属性以指向 c:/kafka/kafka-logs 和 Zookeeper 数据以指向 c:/kafka/zook...
Zookeeper 中的错误:在 Kafka 中创建主题时长度不合理 = 308375649
我正在本地 Windows 10 计算机上设置 Kafka。因此,下载了所有必需的二进制文件,并根据文档更新了两个设置服务器和 Zookeeper 属性。 但跑步时...
我正在开发 Spring Boot + Apache Kafka + Apache Zookeeper 示例。我已经在本地 Windows 计算机上安装/设置了 Apache Zookeeper 和 Apache Kafka。我从链接中获取了参考:https://...
我是 Kafka 新手,我正在尝试使用命令行创建一个主题,但出现以下错误: C:\kafka in\windows>kafka-topics.bat --create --topictutorialspedia --boot...
我有一个在 GCE 上使用 Kubernetes 的集群配置,我有一个用于 Zookeeper 的 pod,还有一个用于 Kafka 的 pod;它一直正常工作,直到 Zookeeper 崩溃并重新启动,并且它开始拒绝
抑制 org.apache.zookeeper.ZooKeeper 的 Log4j 输出
我正在构建一个将利用 org.apache.zookeeper.ZooKeeper 的测试驱动程序。该库正在将嘈杂的输出转储到我想要控制或抑制的控制台。 我试图创造...
我正在将 flink 从 1.14 升级到 1.18 我在 flink-conf.yaml 中有 flink HA Zookeper flink-conf.yaml 高可用性.类型:zookeeper high-availability.storageDir: file:///opt/flink/state_dir/ha/ 高-
在本地 docker 上运行 Kafka、zookeeper 和客户端/生产者。 Kafka 和服务上出现 no Brokers 错误。等待节点分配。在下面的错误中调用:createTopics 让我赢了...
我正在使用ckickhouse并运行查询,但我的clickhouse挂了!。 我重新启动了服务器,但 clickhouse 服务未运行并生成以下日志。 2024.03.10 16:15:23.79850...
Docker - 库初始化失败 - 无法分配文件描述符表 - 内存不足
我一直在尝试在 Docker 容器上运行 Zookeeper 和 Kafka。 我的终端出现很多错误 [错误报告期间发生错误,id 0xb] 和 [错误太多,中止]。然后是图书馆
我是 Kafka 新手,我正在尝试使用命令行创建一个主题,但它给了我以下错误: C:\kafka in\windows>kafka-topics.bat --create --topictutorialspedia --boot...
将 Zookeeper 从 3.6.3 升级到 3.9.1 后,log4j 属性不适用
在我的Java项目中,我在资源下有log4j2.xml文件,它定义了camel、kafka、zookeeper、springframework的每个服务的日志格式和日志级别。我在每个 lo 之前设置了一个时间戳...
为什么有些分布式系统(如 Solr 或 Kafka)需要 ZooKeeper,而有些分布式系统(如 Cassandra)不需要?
情况如下: 我调用的是client.getChildren().forPath("/path"。正常情况下没有问题。 但如果childNode太多,会出现Exception:org.apache.zookeeper.KeeperException$
Kafka + Zookeeper:无法建立与节点-1 的连接。经纪人可能不可用
我在本地主机中运行 Zookeeper 和 Kafka(各 1 个实例)。 我从卡夫卡成功创建了一个主题: ./bin/kafka-topics.sh --zookeeper localhost:2181 --create --replication-factor 1 --