Apache ZooKeeper是一种分布式服务，提供配置信息存储，命名，同步，协调和组服务。
Kafka + Zookeeper：无法建立与节点-1 的连接。经纪人可能不可用
我在本地主机中运行 Zookeeper 和 Kafka（各 1 个实例）。 我从卡夫卡成功创建了一个主题： ./bin/kafka-topics.sh --zookeeper localhost:2181 --create --replication-factor 1 --
在生产 kafka 集群上将 Apache kafka 从 2.7 版本升级到 3.X，无需 Zookeeper
我们有 2.7 版本的生产 Kafka 集群，RHEL 7.9 版本上有 5 个 Kafka 代理 我们想要将Kafka版本升级到3.X版本 3.X版本不包括zookeeper，所以我们想知道我...
Dockerized Spring Boot 应用程序无法通过 localhost 访问主机的 kafka 实例
我有一个 dockerized spring-boot Web 服务，需要生成 Kafka 主题。我在 Ubuntu 上本地运行 Kafka 和 Zookeeper。我的 Web 服务在同一台计算机上的 Docker 中运行。我有
我按照这个官方文档安装了CDH 5.3.2的Kerberos。 我还按照 ZooKeeper 身份验证来配置安全的 ZooKeeper，其中我执行了以下操作： 1）。为
我有以下文件夹结构： 从 C:\Program Files\kafka\kafka_2.11-0.11.0.0 frolder 我尝试执行以下命令： bin\windows\zookeeper-server-start.bat config\zookeeper.properti...
使用go-zookeeper api创建TTL节点总是显示无效参数
我在尝试创建 TTL 节点时遇到问题。在执行相应函数的过程中，我一直遇到“无效参数”错误。我已确保我的
我需要在apache kafka和zookeeper中启用SSL安全吗？有教程吗？我面临信任库路径问题。
我有这个 docker-compose 配置： 卡夫卡： 图片：confluenceinc/cp-kafka：最新 容器名称：'virl-kafka' 重新启动：始终 端口： - “9092:9092” 环境...
我在启动 Debezium PostgreSQL 连接器时遇到问题： 错误 由于错误而停止 (org.apache.kafka.connect.cli.AbstractConnectCli:100) java.util.ServiceConfigurationError：io。
org.apache.kafka.clients.NetworkClient 引导代理 bootstrap-servers-ip:9092 已断开连接
我正在本地系统上运行apache kafka，它运行得非常好。但在冒烟测试期间，我的应用程序无法连接到 kafka 集群。它不断抛出以下内容...
在 Windows 上的 kafka 上获取 java.nio.file.AccessDeniedException
我尝试在Windows上设置kafka和zookeeper。 最初我创建了主题、生产者和消费者。一切正常。 然后我使用以下命令删除了一个主题： kafka-run-class.bat k...
我正在使用 docker-compose 启动一些容器，这些容器形成 Solr 和 Zookeeper 节点的集群。 这是我的撰写文件（取自此处）： 版本：'3.8' 服务： 索尔1： 图片：solr：...
我是容器化新手。我正在尝试设置我的本地环境，我的 java 应用程序想要连接到 Kafka。无法使用 Docker，所以决定使用 Podman。我有三个容器在同一个上运行
让我们想象一个有状态的操作正在进行如下： 聚合 或者 窗口化 然后集群内负责的代理由于某种原因宕机了。 这样的话，会发生什么……
这是我的图表： 姓名：动物园管理员 版本：1.0.0 依赖项： - 名称：bitnami/zookeeper 版本：3.8.1 存储库：https://charts.bitnami.com/bitnami 这就是我的 helm 搜索仓库
为什么Kafka集群中的分区领导者选举逻辑不能放在Zookeeper中而不是controllerbroker中来做？
引用这个答案 - kafka 使用 Zookeeper 来做一些事情： 集群成员资格 - 集群的实时代理是那些拥有 临时 ZK 节点领导者选举 - kafka 经纪人的选举...
k在zookeeper中创建具有TTL值的Znode时出现错误
导入（ “错误” “FMMT” “弦” “github.com/go-zookeeper/zk” ） func ConnectZK() (*zk.Conn, 错误) { zkServers := []string{"loc...
Kafka 生产者由于 LeaderNotAvailableError 无法生成消息
我在kafka和zookeeper方面遇到了一些问题，我有3个kafka经纪人和3个zookeeper。我从我的所有容器中收到几个卡夫卡问题，其中一些有： 时间=“2023-12-26T09:46...
安装zookeeper-client-c时build.xml不存在
我是zookeeper的新手，想用c语言学习zookeeper。 我安装zookeeper-client/zookeeper-client-c(release-3.6.2)按照以下步骤进行。自述文件。 运行时出现一些问题./
当现有端点无法访问时，从 Zookeeper 获取新的服务端点
我正在编写一个与 Zookeeper 集成的应用程序，用于客户端服务发现。该应用程序是一个Python Flask应用程序，在K8s集群中使用gunicorn和Docker部署。它使用 ka...