apache-zookeeper 相关问题

heZookeeper CLI未显示节点数据

[基本上，我已经设置了一个新的zookeeper实例-版本zookeeper-3.6.0。zookeeper已成功启动，并且我能够连接到cli。我试图创建一些示例节点，如下所示...

Apache Curator TestingServer创建会抛出java.lang.NoSuchMethodError

我正在尝试仅运行TestingServer以便能够为其编写单元测试。 val zkServer = new TestingServer（2182）println（zkServer.getPort）我的pom具有以下相关的依赖项...

Java Zookeeper API奇怪的ZNode行为。无法正确删除ZNode。结果出乎意料]]

我正在尝试创建一个持久的ZNode并存储我已处理的特定文件的行数。创建的工作与应该的一样，从节点读取数据也是如此，但是...

[使用PEM文件的Zookeeper TLS设置

我看到zookeeper 3.5.5可以选择传入.PEM文件来设置TLS加密。我有使用openssl生成的服务器certificate.pem和privatekey.pem，并按如下所示设置zookeper配置tickTime = ...

Zookeeper-跟随领导者java.lang.IllegalArgumentException时发生异常

我在AWS EKS集群版本1.15中以复制模式（总共3个Zookeeper节点）运行Zookeeper 3.6.0。我正在从Docker集线器中获取zookeeper：最新图像。这是节点1的zoo.cfg文件...

Kafka经纪人意外关闭

在kafka / zookeeper v2.4.1（二进制kafka_2.13-2.4.1.tgz的单个群集/实例安装中，kafka代理在清理日志文件期间意外关闭，并显示以下错误消息：...

具有偏移量管理功能的Python Kafka使用者

我是Kafka的新手，我正在尝试在Kafka中建立一个消费者，以便其读取Kafka Producer发布的消息。如果我错了，请纠正我，如果我能了解卡夫卡消费者商店的话，请改正我的方式...

Kafka为什么不连接到Zookeeper？

我正在与Rasbian一起使用pibery pi。我想使用Kafka将相机中的数据流式传输到我的手机。我从包含Zookeeper和Kafka的Kafka网站下载了此软件包：https：// www ..

解决来自Kafka的Zookeeper NoSuchMethodError

[我在运行/bin/kafka-server-start.sh /config/server.properties 2020-02-27T13：23：34,540时遇到此错误[main] kafka.server.KafkaServer-[KafkaServer id = 0 ] ...

清理使用Apache策展人创建的锁

我是Apache Curator的新手，并希望使用Apache Curator确认与分布式锁相关的几件事：在创建InterProcessMutex实例时，我将锁路径提供为“ lock / unique_id”。 ...

使用Kafka启动Zookeeper时出错

虽然在Windows 10上使用Kafka运行Zookeeper时出现以下错误：kafka_2.12-2.4.1> bin \ windows \ zookeeper-server-start.bat config \ zookeeper.properties输入行太长。 ...

无法启动服务Zookeeper：驱动程序无法在端点上编程外部连接

[这个问题与如何为在MSSQL Server的Docker中运行的Kafka设置Debezium有关，我试图通过本教程运行本教程，并通过本教程将Debezium与MSSQL Server一起使用：...

使用Golang连接到kafka时如何设置zookeeper chroot路径？

[使用Kafka工具，我的配置类似于：Zookeeper主机：192.168.60.97 Zookeeper端口：2181 chroot路径：/ kafka1但是，当我尝试使用此使用者时，err = sarama.NewConsumer（[] string {“ 192.168.60.97:2181： / ...

如何在Windows中运行zookeeper.sh文件

我正在阅读本教程，在这里我必须运行此命令才能启动Zookeeper服务器。 ./bin/zookeeper-server-start.sh config / zookeeper.properties但问题是此命令是...

Zookeeper弹性

我们有17名经纪人和5名动物园管理员的集群。我想测试动物园管理员的弹性。因此，我删除了3个动物园管理员，因为我的理解是，对于具有5个动物园管理员的集群，它的最大中断是...

观看/ zookeeper / config更改以更新策展人连接字符串是一个好主意吗？

我希望我的zookeeper客户端（Curator Framework）在仲裁配置更改时跟踪最新的服务器，因此我提出了添加一个侦听器（Curator NodeCache）以监视/ zookeeper / config的想法。 ...

Windows 10 java.net.BindException：地址已在使用中：在所有端口上绑定

我正在尝试从Windows命令行中启动Zookeeper实例。无论我尝试在哪个端口上，都会出现错误java.net.BindException：地址已在使用中：在sun.nio.ch.Net上绑定....

java-[Apache Curator]如何正确关闭策展人

[我正在尝试使用Apache Curator在与Zookeeper的连接上实现后备逻辑，基本上我有两组连接字符串，如果我在状态侦听器上收到LOST状态，我会尝试...

Zookeeper的主题删除

我使用以下命令直接从Zookeeper中删除了主题，之前没有从Kafka中执行删除：zookeeper-shell.sh localhost：2181 rmr / brokers / topics / 现在...

是否可以在一台机器上以不同的端口运行多个Zookeeper实例？

我正在尝试在具有不同日志目录的两个不同端口上启动kafka集群所需的两个zookeeper实例。但是，当我尝试启动第二个Zookeeper时，出现以下错误-...