apache-zookeeper 相关问题

我可以在 AWS MSK 上以 KRaft 模式使用 Kafka 吗？

我想在KRaft模式下使用Kafka而不是AWS上的Zookeeper，因为Kraft模式似乎是Kafka的未来。据我了解，AWS针对Kafka的基本解决方案是AWS MSK。但在 MSK

Zookeeper f-sync 问题导致 Kafka 超时

我们正在尝试在具有 16 核和 16 GB RAM 的 VM 上为 Zookeeper 和 Kafka 进行单节点安装。 Zookeeper 显示 f-sync 问题，并且在设置的 6000 毫秒超时期限之后 kafka gi...

ListAzureBlobStorage 无法从 ZooKeeper 获取具有 ID 的组件的值

ListAzureBlobStorage 在设置下运行良好： 。 直到它因以下错误而失败，而没有进行任何更改。我已经重新启动nifi并再次重置所有属性。然而，...

Apache Flink HA - 选择的领导者错误的 URL

拥有具有 HA 的 Flink 集群 1.19.0，询问 zk“leader/resource_manager/connection_info”，它显示领导者的 IP：既不是 localhost，也不是 127.0.0.1。这是网络可访问的IP值。

Kafka消费者在docker中收不到消息

我正在为 Kafka 创建一个非常基本的消费者/生产者设置。我正在使用 Zookeper 和 Kafka 以及 Docker compose。两者似乎都有联系，但当涉及到生产或消费时，没有什么……

Kafka Broker 身份验证失败 - 凭据无效

在最后一天左右的时间里，我尝试使用融合的 docker 镜像在本地设置一个节点的 Kafka 集群。不幸的是，一直未能做到这一点。以下是我的所有配置文件： /etc/卡夫卡/

ZooKeeper zkCli 不使用配置的日志目录

我正在运行 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...

使用zookeeper在spark上配置ACL

我已将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 属性。 但跑步时...

org.springframework.context.ApplicationContextException：无法启动bean'org.springframework.kafka.config.internalKafkaListenerEndpointRegistry

我正在开发 Spring Boot + Apache Kafka + Apache Zookeeper 示例。我已经在本地 Windows 计算机上安装/设置了 Apache Zookeeper 和 Apache Kafka。我从链接中获取了参考：https://...

Kafka createTopics 失败

我是 Kafka 新手，我正在尝试使用命令行创建一个主题，但出现以下错误： C:\kafka in\windows>kafka-topics.bat --create --topictutorialspedia --boot...

Zookeeper 拒绝老客户端的 Kafka 连接

我有一个在 GCE 上使用 Kubernetes 的集群配置，我有一个用于 Zookeeper 的 pod，还有一个用于 Kafka 的 pod；它一直正常工作，直到 Zookeeper 崩溃并重新启动，并且它开始拒绝

抑制 org.apache.zookeeper.ZooKeeper 的 Log4j 输出

我正在构建一个将利用 org.apache.zookeeper.ZooKeeper 的测试驱动程序。该库正在将嘈杂的输出转储到我想要控制或抑制的控制台。 我试图创造...

flink 1.14升级到1.18时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-compose Kafka：没有可用的代理

在本地 docker 上运行 Kafka、zookeeper 和客户端/生产者。 Kafka 和服务上出现 no Brokers 错误。等待节点分配。在下面的错误中调用：createTopics 让我赢了...

重启后无法启动clickhouse服务

我正在使用ckickhouse并运行查询，但我的clickhouse挂了！。 我重新启动了服务器，但 clickhouse 服务未运行并生成以下日志。 2024.03.10 16:15:23.79850...

Docker - 库初始化失败 - 无法分配文件描述符表 - 内存不足

我一直在尝试在 Docker 容器上运行 Zookeeper 和 Kafka。 我的终端出现很多错误 [错误报告期间发生错误，id 0xb] 和 [错误太多，中止]。然后是图书馆