apache-zookeeper相关内容
我已经用SASL+ACL设置了Kafka和ZooKeeper身份验证,Kafka通过包含加密的SSL双向身份验证设置到生产者和消费者。 通过在Kafka和ZooKeeper之间启用SASL和ACL,不允许未经授权的Kafka Broker登录到ZooKeeper集群。但是,主题的创建和删除仍然可以不受任何限制。 zookeeper.properties dataDir=/x02/
..
我正在尝试使用以下命令运行本地群集: storm local target/myjar.jar com.app.MyMainClass Storm响应此错误: WARN o.a.s.s.o.a.z.ClientCnxn - Session 0x0 for server localhost/:2000, unexpected error, closing s
..
我可以使用Kafka Broker和嵌入式ZooKeeper(由Kafka提供)进行Digest-MD5身份验证,但在使用Kafka Broker和非嵌入式ZooKeeper(单独的ZooKeeper实例)进行Digest-MD5身份验证时收到以下错误消息。 请查看以下错误消息: [2018-11-05 19:44:21,536] ERROR SASL authentication f
..
在我的 zookeeper/conf/log4j.properties 文件中,我将 zookeeper.log.dir 设置为 $HOME/zklogs 当我使用 zkServer.sh 时,它不使用该目录.相反,它使用 ${ZOO_LOG_DIR} ,当我回显它时,它会出现在“." 我不明白如何解决这个问题,我在任何地方都没有看到 ${ZOO_LOG_DIR} 设置.我不确定它是如
..
类 Dynamo 数据库(例如 Cassandra)可以通过仲裁来强制一致性,即应该以 W+R 的方式选择多个同步写入的副本 (W) 和多个要读取的副本 (R)>N 其中 N 是复制因子.另一方面,Zookeeper 等基于 PAXOS 的系统也被用作一致的容错存储. 这两种方法有什么区别?PAXOS 是否提供 W+R>N 模式未提供的保证? 解决方案 Paxos 实施起来并不简单,
..
我是 Solr 的新手,正在试验 SolrCloud - 似乎 ZooKeeper 是管理高可用性的最佳方式. 然而,在我们的生产环境中,我们只有两台服务器(主动-主动),我担心 Zookeeper 在两台服务器上并不理想,因为如果其中任何一个出现故障,整个集成都会停止工作.目前的解决方法是在 server1 上运行两个 ZK,在 server2 上运行一个 ZK,这样至少如果 server
..
我一直在尝试使用 Kubernetes 在本地部署带有架构注册表的 Kafka.但是,架构注册表 pod 的日志显示此错误消息: ERROR 服务器意外死亡:(io.confluent.kafka.schememaregistry.rest.SchemaRegistryMain:51)org.apache.kafka.common.errors.TimeoutException:获取主题元数据时
..
我已经使用独立的 zookeeper 设置了 SolrCloud 复制.但现在我希望对我的 Schema.xml 进行一些更改并重新加载核心.问题是,当我运行单个服务器 Solr(无 solrcloud)时,会加载新模式,但我不知道如何在所有复制服务器上重新加载模式.我尝试在其中一台服务器上重新加载架构,但没有预期的影响.有没有办法在使用zookeeper的分布式复制设置中在Solr中重新加载我的
..
我有一个与延迟基准测试相关的问题.我在 5 台机器的集群中运行 Apache ZooKeeper(一个领导者,其余是追随者).还有另一台机器(客户端)用于对向协议发送请求进行排序. 我设法运行了一个基准程序,该程序持续预选的时间,旨在同时且连续地向每个 ZooKeeper 服务器发送请求.当预先选择的时间过去后,我可以看到延迟结果. 然而,上述基准测试仅使用一台客户端机器来运行基准测试
..
嗨,我是 hbase 的新手,正在尝试练习它.首先,我想描述一下系统配置.背景: 我使用的是 Windows 7 并安装了 Oracle Virtual Box.然后在 Virtual Box 上安装了 ubuntu 服务器,之后我在 ubuntu 上安装了 hbase0.98-hadoop2-bin.tar.gz.我已经在独立模式下配置了 hbase.我的 hbase-site.xml 文
..
我有一个 Nifi 集群,一个 Zookeeper 节点和五个 Nifi 节点.我想从zookeeper服务器到Nifi客户端进行SSL加密.阅读 Nifi 文档,它说: ZooKeeper 中对 SSL 的支持正在积极开发中,预计将在 3.5.x 发行版中提供. 新的 zookeeper 3.5.3-beta 具有 SSL 功能.我安装了 zookeeper 3.5.3,但我无法使用
..
有一个问题困扰着我.EndOfStreamExceptionalways 在提交拓扑后发生在zookeeper中.虽然不影响集群的正常运行,但还是希望能解决这个问题,因为可能会影响到Heron的其他部分功能.zookeeper 版本是 3.4.10,部署在我集群的一台主机上的独立模式下.zoo.cfg 的内容如下. tickTime=10000initLimit=100同步限制=50dataDi
..
目前我有一个 zookeeper 实例控制 3 台物理服务器上的复制.它是solr集成的zookeeper.1 个分片,1 个集合. 我有一个新需求,我需要一个新的静态 solr 实例(1 个新集合,无复制).与之前的集合相同的架构.此实例的副本也将放置在上述 3 台物理服务器上.需要注意的是,我需要在 2 个集合中执行分布式搜索并混合结果. 感谢 javacreed 我现在知道分片不
..
我正在尝试为 ZooKeeper 安装 C 绑定,同时使用构建系统 i386-pc-solaris2.11(我不知道这是否重要)连接到另一台计算机.无论如何,我连接到的计算机正在运行基于 linux 的操作系统. 我在命令行中运行了以下代码: cd ../zookeeper光盘源CDC./配置制作 上面的终端输入取自 Apache 网站,用于设置 C shell 客户端.我得到的错误代码
..
我们正面临 solr/zookeeper 的问题,其中 zookeeper 在 10000 毫秒后超时.以下错误. SolrException: java.util.concurrent.TimeoutException: 无法在 10000 毫秒内连接到 ZooKeeper :9181、:9182、:9183.在 org.apache.solr.common.cloud.SolrZkClien
..
我在使用 SolrCloud 时遇到了一个有趣的情况.基本上,我不知道为什么,但是通常不在云中的 Solr 实例显示在 SolrCloud 页面上,并且在 Zookepeer 的 live_nodes 路径中也可见. 以下是有关情况的详细信息: 我有一个 Solr 实例,作为独立应用程序在虚拟机上运行,位于移除机器上.从现在起,我们将称之为 virtual1. 这是运行它的脚
..
我们有 3 台 kafka 机器和 3 台 zookper 机器 kafka机器和zookeper机器分开,所有机器都是OS-redhat 7.x 在/var/log/kafka下我们可以看到如下,java.io.IOException显示在server.log中> at kafka.utils.ShutdownableThread.run(ShutdownableThread.s
..
在动物园管理员中,我可以使用zookeeper.exists(path,false)来检查路径是否存在.但是如果路径存在,我可以使用女巫方法来获取路径的创建模式吗?(持久或临时) 解决方案 On this call :zookeeper.exists(path,false) ..Zookeeper 服务器将返回一个 Stat 结构.从 Stat 结构中检查属性 "ephemeralOwne
..
我在 Ubuntu 14 上安装了 zookeeper,但是当运行命令时它失败了.命令是:cat/var/log/kaa/* |grep 错误 它显示:2017-04-19 00:20:04,197 [main] ERROR o.k.k.s.n.s.i.KaNodeInitializationService - 无法在 5 分钟内连接到 Zookeeper.Kaa 节点服务器将停止.2017
..
使用以下命令运行 PubSub Kafka 连接: .\bin\windows\connect-standalone.bat .\etc\kafka\WorkerConfig.properties.\etc\kafka\configSink.properties .\etc\kafka\configSource.properties 我收到此错误: 向节点-1发送元数据请求{topics=[
..