apache-zookeeper相关内容
我在 CDH 集群 5.7.0 中运行 HBase.几个月没有任何问题运行后,hbase 服务停止了,现在无法启动 HBase 主服务器(1 个主服务器和 4 个区域服务器). 当我尝试在某个时候启动它时,机器挂起,我在主日志中看到的最后一件事是: 2016-10-24 12:17:15,150 INFO org.apache.hadoop.hbase.util.FSHDFSUtils:恢
..
我正在为 Kubernetes 使用官方稳定的 ZooKeeper Helm 图表 它从 Google Container Registry 上的 Google 示例镜像中提取 ZooKeeper Docker 镜像. 该 ZooKeeper 映像可用 here,但是,我似乎无法找到对 Dockerfile 的任何参考,了解它的构建方式,或者它的 Dockerfile 是否是从其他一些表示生
..
我们为主题设置retention bytes值 - 104857600 - topic_test [root@confluent01 ~]# kafka-topics --zookeeper localhost:2181 --alter --topic topic_test --config reserved.bytes=104857600警告:从此脚本更改主题配置已被弃用,可能会在未来版本中删
..
我找不到任何直接处理我面临的问题的东西,所以我在这里发帖.我有 JUnit/JBehave 测试,可以启动嵌入式 ZooKeeper 服务器、嵌入式 Kafka 服务器以及 kafka 生产者和消费者. 将 kafka 从 0.7 升级到 0.8.1.1 后,我遇到以下类型的错误: ERROR [kafka-request-handler-5] state.change.logger -
..
我正在使用 Jetty 8 和 ZooKeeper 3.4.5.当我连接到 ZooKeeper 时,jetty 不断生成 DEBUG 级别的消息.怎么压制? 16:54:56.757 [main-SendThread(127.0.0.1:2181)] DEBUG o.a.z.client.ZooKeeperSaslClient - 无法检索登录配置:java.lang.SecurityExc
..
我正在使用一个 Java 应用程序,它启动消费者阅读 Kafka 主题.每次需要启动消费者应用程序时,我都必须使用cmd中的命令启动Zookeeper和Kafka服务器.是否可以使用小型 Java 程序启动/停止它们?谢谢. 解决方案 请看这个话题,是关于用Java启动Zookeeper的: 从java程序启动zookeeper服务器的最佳方式 指向这个: 是否可以在进程
..
如何以编程方式检测客户端连接到 ZooKeeper 集合中的哪个服务器? 我正在使用 Apache Curator API,我正在通过注册
..
我在尝试为本地开发 Windows 7 工作站启动 Storm nimbus 时遇到以下错误:错误:无法找到或加载主类 Files\Java\jdk1.8.0_92\bin;C:\Program storm.yaml: storm.zookeeper.servers:- “127.0.0.1"nimbus.seeds: ["127.0.0.1"]Storm.local.dir: "C:\\
..
我正在尝试在我们的 Kafka 环境中使用 SSL 配置 SASL/PLAIN.SSL 部分已完成,但我在启动 Zookeeper 时遇到以下错误. 有没有人为 Zookeeper 和 broker 配置了 SASL/PLAIN 和 SSL? 服务器代理配置 broker.id=19端口=19001#host.name=本地主机主机名=jcia9081#advertised.host.n
..
首先,我创建一个名为 usercollection 的集合: http://xxxxx/solr/admin/collections?action=CREATE&name=usercollection&numShards=3&replicationFactor=3&maxShardsPerNode=3 然后我发现不对的地方,所以我删除了. http://xxxx/solr/admin/co
..
我使用 kafka 作为微服务架构的消息总线,因此多个服务监听一个主题以获取消息.因此,服务高度依赖于要直播的主题. 但是,在很多情况下,我会在主题上获得 leader not available、broker not available 和 leader= - 1. 现在,我不确定是否可以依赖 kafka 主题,因为当主题出现问题并导致平台出现问题时,服务会中断. 有人可以对这
..
我的问题是 Storm KafkaSpout 在一段时间后停止使用来自 Kafka 主题的消息.在 Storm 中启用调试时,我得到这样的日志文件: 2016-07-05 03:58:26.097 oasdtask [INFO] 发射:packet_spout __metrics [#object[org.apache.storm.metric.api.IMetricsConsumer$Ta
..
我正在将 ZooKeeper 拉入一个项目以进行一些并发管理,我尝试的第一件事对我来说很明显(使用 zkpython 绑定): zh = zookeeper.init('localhost:2181')zookeeper.create(zh, '/path/to/a/node', '', [ZOO_OPEN_ACL_UNSAFE]) 我收到了一个 NoNodeException 来解决我的问题
..
我有一个 Zookeeper 集成,我想从 3.3.X 升级到 3.4.X 分支.这可以在实时集群上完成吗?需要停机吗?有什么可以在某处找到的说明吗? 解决方案 从我查到的, 升级 ZooKeeper 的选项/过程是什么? 有两种主要方法可以做到这一点;1) 完全重启或 2) 滚动重启. 在完全重启的情况下,您可以暂存更新的代码/配置/等...,停止集合中的所有服务器,切
..
我们有一个旧的 zookeeper 3-cluster quorum,一些永久路由信息存储在 znodes/data 中.现在我们正在不同的数据中心设置另一个全新的 3 集群仲裁,我们希望将路由信息迁移到它.执行此操作的最佳可靠方法是什么? 会简单的复制事务日志吗?还是用快照更好?或者是否有一些工具可以从旧 znode 中提取数据并将创建重播到新 znode 上? 找到类似问题,但没有
..
如 ZooKeeper 入门指南中所述,容错集群设置至少需要三台服务器,强烈建议您使用奇数台服务器. 所以如果我有 5 台服务器,并且如上所述,当其中 2 台发生故障时我仍然可以生存.但这意味着同时或累积 ?? 那么这个怎么样: 5台服务器->失败1台->4台服务器->失败1台->3台服务器->失败1台->2台服务器->失败1台->死 3台服务器(初始化)和3台服务器(5台服务
..
嗯..世界上的每个服务都可以连接到我的动物园管理员,除了 kafka.下面是我在 server.properties 文件中的连接字符串 zk.connect=1.dzk.syd.druid.neo.com:2181, 2.dzk.syd.druid.neo.com:2181 在两个zookeeper服务器上拥有所有端口......完全混杂模式.我什至可以从kafka服务器telnet到zoo
..
我使用的是 solr 4.10.3,我通过 Java 中的嵌入式码头服务器启动 solr.我正在尝试使用 2 个分片(Leaders)配置 solrcloud.我有一个外部zookeeper设置,我在像这样启动solr时指向zookeeper实例. System.setProperty("zkHost", "192.168.2.21:2111");System.setProperty("num
..
我是 SolrCloud(4.X) 的新手,谁能详细解释一下 Zookeeper 在 SolrCloud 中的角色和职责?另外,zookeper 在向 Solr 搜索/添加请求方面是如何工作的? 解决方案 Zookeeper 是 SolrCloud 配置的中央存储库.您可以将其视为一个分布式文件系统,集群中的所有 Solr 节点都可以访问它.因此,如果您更改任何配置文件,您只需将其通知或上
..
我正在使用一个将运行 ZooKeeper 的容器,但我遇到了我安装到容器中的主机卷的权限问题. 这是我的设置: 在主机 (Ubuntu 14.04) 上: 创建了“zookeeper"系统用户 (id=106) 和群组 (id=111). 创建目录“/var/log/zookeeper"并将其所有权设置为zookeeper(即chown zookeeper:zookeeper)
..