apache-zookeeper相关内容
我在运行 Zookeeper 和 ActiveMQ 的 3 个虚拟机中配置了这个端口. root@mom3:~# ufw status verbose状态:活跃记录:开(低)默认值:拒绝(传入)、允许(传出)、禁用(路由)新配置文件:跳过行动自——————————22 允许在任何地方2881 允许在任何地方2888 允许在任何地方3888 允许在任何地方61616 允许在任何地方61617 允许
..
@RequestMapping(value = "/getTopics",method = RequestMethod.GET)@ResponseBody公共响应 getAllTopics() {ZkClient zkClient = new ZkClient(ZookeeperProps.zookeeperURL, ZookeeperProps.connectionTimeoutMs,Zook
..
我正在编写一个基于 Kafka 的集群应用程序——它专门使用 Kafka 进行进程间通信和协调.我可以使用 Zookeeper 来管理我的集群——但是使用 Kafka 主题来管理集群并不是很困难.而且我想得越多,除了历史原因,似乎Kafka可以放弃Zookeeper,只使用基于主题的解决方案 例如,Kafka 中可能有一个或多个特殊主题,您可以在其中发布当前在 Zookeeper 中跟踪的所
..
我有一个包含 3 个集合的 zookeeper 实例(Solr 集成版本).每个集合在其 conf 目录中都有一个不同的 schema.xml.Zookeeper 成功启动 - 目标是在不同的集合中进行分布式搜索.我的问题是,当我通过管理工具查看 collection2 和 collection3 的架构时,它们似乎都在使用 collection1 架构.所以我不能更新集合 2 &3 因为他们缺少
..
当我想用命令行启动 Zookeeper-Server 时,我收到系统找不到路径的消息.昨天一切都很好,代码/路径是正确的.今天系统找不到路径. 这是我在 Windows 7 上以“管理员身份"打开的 cmd.exe 窗口的内容: C:\Users\KESSP2>cd 文档C:\Users\KESSP2\Documents>cd kafkaC:\Users\KESSP2\Documents\
..
我希望得到有关 accumulo、zookeeper hadoop 安装说明、下载和 CENTOS 6 版本的指导. 谢谢, 克里斯 解决方案 您可以通过 cloudera manager 版本 5 进行安装.我最近使用相同的版本安装了 accumulo. 这是 Cloudera 管理器 5 的链接. 您可以使用这个 Youtube 视频作为参考.
..
我在 Mac(带 docker-machine)上的 Docker 中运行 Kafka (0.10.0.0).我从 Spotify 派生了我的 Dockerfile,这意味着 Kafka 和 Zookeeper 在同一个镜像中运行. 我的实例开始干净利落并在里面探查出现一切正常/正常. 在这种情况下,Docker 将端口 2181 和 9092 映射到高端口 32822 和 32820
..
标题可能看起来很傻,但我真的无法理解当master宕机时zookeeper的故障转移策略,尽管我阅读了很多关于Zookeeper的文档.我的问题如下: 如果我有3个节点zookeeper,那么master宕机了,那怎么办剩下的两个节点选举新的主节点(现在是偶数编号节点,它们如何通过多数投票). 如果剩下的一个两个节点宕机,那么最后一个将成为主节点并不断请提供服务,好吗? 如果偶数个zoo
..
我正在尝试在 Azure Kubernetes 服务中将 zookeeper 作为集群运行.所有实例都以 myid:1 开头,不确定我需要更改什么配置.任何帮助表示赞赏. 这是我的配置文件, apiVersion: v1种类:服务元数据:名称:zk-hs标签:应用程序:zk规格:端口:- 端口:2888名称:服务器- 端口:3888名称:领导人选举集群IP:无选择器:应用程序:zk---a
..
我正在使用 zookeeper c 客户端库.当我运行我的程序时,它会将 ZOO_INFO 输出到控制台.部分日志消息如下所示: 2015-03-26 20:08:22,115:15978(0x7f83a1fbc740):ZOO_INFO@log_env@712: 客户端环境:zookeeper.version=zookeeper C 客户端 3.4.6 2015-03-26 20:0
..
我有 Kafka Stream 应用程序.我的应用程序正在成功处理事件. 如何使用所需的偏移量更改 Kafka 提交的消费者偏移量以重新处理/跳过事件.我尝试了如何更改主题的起始偏移量?.但我收到“节点不存在:"错误.请帮帮我. 解决方案 您所指的问题/答案基于较旧的 Kafka 版本.从 Kafka 0.9 开始,偏移量不再提交给 ZooKeeper,而是存储在一个名为 offse
..
我已经安装了 Hive,但是当我编写命令来创建表“CREATE TABLE foo(id int, msg STRING);"时.我抛出异常“清理操作已完成失败:元数据中的错误:javax.jdo.JDOFatalDataStoreException:无法创建数据库“metastore_db",有关详细信息,请参阅下一个异常.NestedThrowables:java.sql.SQLExcepti
..
我正在努力安装 Kafa 和 Zookeeper. 我已经运行了 Zookeeper,它目前正在运行.我在 [https://dzone.com/中设置了所有内容文章/running-apache-kafka-on-windows-os] 当我终于在我的 cmd 中运行时, .\bin\windows\kafka-server-start.bat .\config\server.pr
..
如何解决产生此错误的问题: WARN [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:ZooKeeperServer@1040] - 客户端未能通过 SASL 身份验证:javax.security.sasl.SaslException:GSS 启动失败 [由 GSSException 引起:失败在 GSS-API 级别未指定(机制级别:校验和失败)]jav
..
我已经在上面安装了 cloudera 和 hdfs、mapreduce、zookeper、hbase.具有这些服务的 4 个节点(3 个动物园管理员).所有都由 cloudera 向导安装,并且在 cloudera 中没有配置问题.从 java 连接时出现错误: 9:32:23.020 [main-SendThread()] 信息 org.apache.zookeeper.ClientCnx
..
我在 Java 中使用 curator 框架与 ZNodes 进行交互.我们如何获取节点统计信息,如 last_modified 时间和创建时间等.我可以使用 kazoo 框架在 python 中做同样的事情. from kazoo.client import KazooClientzk_client = KazooClient(hosts='127.0.0.1:2181')zk_client.
..
是否有计算我需要的zookeeper服务器数量的公式?假设一个集群可能有 50、500 或 5000 台服务器在运行,我如何将这些数字转换为我想要启动的 Zookeeper 服务器数量? 换句话说,zk 服务器可以处理的工作负载是多少?是基于存储大小、仲裁接收的 QPS 还是其他一些指标? 解决方案 ZooKeeper 服务器的集合(集群)可以处理的工作负载主要取决于应用程序执行的写
..
我一直在尝试实现 SolrCloud,一切正常,直到我尝试创建一个包含 6 个分片的集合.我的设置如下: 5 个虚拟服务器,全部运行 Ubuntu 14.04,由一家公司在不同的数据中心托管 3 个运行 ZooKeeper 3.4.6 的服务器用于集成 2 个服务器,每个运行 Solr 5.1.0 服务器 (Jetty) 每个 Solr 实例都有一个用于索引的 2TB ext4 辅助磁
..
我在zoo.cfg中设置:clientPort=2181 cloudera@cloudera-vm:/$ sudo/usr/lib/zookeeper/bin/zkServer.sh start 我收到以下回复: 默认启用JMX使用配置:/usr/lib/zookeeper/bin/../conf/zoo.cfg启动zookeeper ... STARTED cloudera@cl
..
我正在开发全新的 SolrCloud - ZooKeeper 基础架构. 一些背景信息: 所有其他服务(主要是网站基础设施)分布在两个数据中心,采用主动-主动配置. 在网络级别,服务器设置在扩展 LANS 上,并在数据中心之间使用暗光纤.因此延迟最小. 大多数这些应用程序将使用 SolrCloud - ZooKeeper 基础架构. 我有一个 Solr Cloud 和一个 Z
..