《zookeeper》专题
-
Docker在无法连接到kafka的Azure容器实例上使用zookeeper、kafka和python脚本编写多容器
我正在尝试使用zookeeper/kafka非集群设置，以便能够使用python脚本与容器对话。我希望能够运行一个zookeeper/kafka容器和2个或多个容器，其中包含与zookeeper-kafka通信的python脚本，所有这些容器都在Azure上的容器或容器组中运行。 为了测试这一点，我创建了下面的docker容器组，其中zookeeper和kafka作为2个服务，第3个服务启动一个简
-
zookeeper日志中的couch base-Kafka-连接器错误
我对Couchbase和Kafka很陌生。每当我在Couchbase桶中插入消息时，说“xyz”，连接器就会将其拾取并放入同名的kafka主题中，即“xyz“。到现在为止，一直都还不错。但在这里，我有一个kafka消费者正在运行，它阅读这个主题，并将其放入另一个主题中，比如“abc_123”，但这从未发生过。主要是我在动物园管理员（我作为kafka的一部分运行）中看到了这个错误，并想知道，这是不是
-
zookeeper在哪里存储kafka集群和相关信息？
我所说的集群信息指的是这样的信息 < li >订阅的消费者/消费者群体 < li >读取和提交的偏移量 < li >分区的领导者和追随者 < li >关于服务器等的主题。 zookeeper是将这些信息保存在自己的数据库中（尽管我之前从未听说zookeepher有自己的数据库），还是将这些信息存储在Kafka集群中的一些主题等？ 编辑：以及后续问题：动物园管理员如何从__consumer_offs
-
如何选择zookeeper和regionserver
设置regionserver和zookeeper仲裁的好做法是什么？ 我有一个16个节点的小型hadoop集群。按照http://hbase.apache.org/book/example_config.html中给出的示例，我选择16个节点作为regionserver，并选择这些节点的一个子集作为Zookeeper。 但当一个作业由不在与HBase.zookeeper.quorum对应的列表中的
-
Java客户端无法连接到Zookeeper和HBase
我编写了一个简单的HBase客户端程序来在我的HBase集群（1个主服务器和3个区域服务器）中执行CRUD操作。Zookeeper实例仅在主服务器中运行，仲裁包括所有4台服务器。集群运行良好，可以使用YCSB客户端执行读/写操作（意味着服务器/Zookeeper端没有任何错误）。 现在，在eclipse类路径中，我添加了所有HBase库和hbase-0.94.7.jar（包含hbase-defau
-
Kafka Zookeeper连接问题
我用的是Kafka 0.8.2-beta，有2台Ubuntu 14虚拟机: 172.30.141.127正在运行动物园管理员 172.30.141.184在经营一家Kafka经纪人 我正在启动动物园管理员实例，如果一切顺利的话。然后，我尝试启动代理并将其连接到172.30.141.127:2181。它似乎能够在特定的端口上连接并建立会话，但是由于一些似乎没有记录的异常，它失去了连接。 代理输出：
-
如何从命令提示符下检查ZooKeeper是在运行还是up？
我探索了几个设置Kafka的选项，我知道动物园管理员必须启动并运行才能启动Kafka。 我想知道如何才能找到以下内容。 1）我的动物园管理员实例的主机名和端口---我检查了zoo.cfg，我只能找到ClientPort而不是主机名，主机名会是我盒子的主机名吗？？ 2)检查ZooKeeper是否启动并运行——我尝试执行< code>ps -ef | grep "zoo"操作，但什么也找不到。可能是我
-
我怎样才能将 kafka 作为单独的 docker 镜像安装和运行，而不是 Zookeeper
以下是我用来安装 zookeeper 的当前 Dockerfile ，然后在 CentOS 容器上运行它： 我最困惑的是我如何让两个服务作为单独的图像/容器运行，但仍然相互交互。https://stackoverflow.com/a/45111909/12585645 我也不知道如何将它设置为一个集群。如果可能的话，我宁愿不用docker compose。
-
Kafka Manager是否应该单独安装Zookeeper？
在Kafka-manager github页面中写道: 最低配置是用于kafka管理器状态的zoo门主机。这可以在conf目录的application.conf文件中找到。相同的文件将打包在分发zip文件中；您可以在所需服务器上解压缩文件后修改设置。 Kafka-manager . ZK hosts = " my . zookeeper . host . com:2181 "您可以通过逗号分隔来指
-
Kafka：从ZooKeeper获取代理主机
出于特殊原因，我需要同时使用 （又名高级消费者）和 （又名低级消费者）来读取 Kafka。对于 ，我使用基于 ZooKeeper 的配置，并且对此完全满意，但 需要实例化种子代理。 我不想同时保留动物园管理员和经纪人主机的列表。因此，我正在寻找一种方法，从ZooKeeper中自动发现特定主题的经纪人。 由于一些间接的信息，我相信这些数据存储在ZooKeeper中的以下路径之一： < li > <代
-
Kafka Zookeeper:无法建立到节点-1的连接。经纪人可能不可用
我在Zookeeper和Kafka（各1个实例）中运行我的locahost。 我成功地从Kafka创建了一个主题： Kafka日志显示： 但Zookeeper的日志显示： 如果我尝试生成消息： server.properties（在Kafka中）是： 看来动物园管理员没有注册任何经纪人。 有什么建议吗？
-
如何处理 kubernetes 中 kafka 和 zookeeper 的失败 senario
我在服务器1、服务器2和服务器3上运行zookeeper设置，同样kafka也在服务器1、服务器2和服务器3上运行。 安装程序正在kubernetes中运行。 问题陈述： > 如果一个动物园管理员设置关闭，整个设置都会关闭，因为kafka依赖于动物园管理员。我说得对吗？ 如果Q1正确-是否有任何方法来进行设置，例如如果一个动物园管理员服务器将停机，那么kafka应该按原样运行？ 如何在kubern
-
Zookeeper为什么不使用我的log4j.properties文件日志目录
问题内容： 在我的zookeeper / conf / log4j.properties文件中，将zookeeper.log.dir设置为$ HOME / zklogs 当我使用zkServer.sh时，它不使用该目录。而是使用$ {ZOO_LOG_DIR}，当我回显它时，它显示为“”。 我不了解如何解决此问题，也看不到任何地方设置的$ {ZOO_LOG_DIR}。我不确定如何将其设置为“。” 完
-
Zookeeper 如何选举master 主节点？本文向大家介绍Zookeeper 如何选举master 主节点？相关面试题，主要包含被问及Zookeeper 如何选举master 主节点？时的应答技巧和注意事项，需要的朋友参考一下 还记得上面我们的所说的临时节点吗？因为 的强一致性，能够很好地在保证 在高并发的情况下保证节点创建的全局唯一性 (即无法重复创建同样的节点)。 利用这个特性，我们可以 让多个客户端创建一个指定的节点 ，创建成功的就是
-
Zookeeper 如何实现分布式锁?
本文向大家介绍Zookeeper 如何实现分布式锁?相关面试题，主要包含被问及Zookeeper 如何实现分布式锁?时的应答技巧和注意事项，需要的朋友参考一下 分布式锁的实现方式有很多种，比如 、数据库 、 等。个人认为 在实现分布式锁这方面是非常非常简单的。 上面我们已经提到过了 zk在高并发的情况下保证节点创建的全局唯一性，这玩意一看就知道能干啥了。实现互斥锁呗，又因为能在分布式的情况下，所以