zookeeper相关内容
来自 ZooKeeper 常见问题: 可靠性:单个 ZooKeeper 服务器(独立)本质上是一个协调器没有可靠性(单个服务节点故障会导致 ZK 服务中断).一个 3 服务器集合(你需要跳到 3 而不是 2 因为 ZK 工作基于简单的多数投票)允许单个服务器失败并且该服务仍将可用.因此,如果您希望可靠性至少选择 3.我们通常建议在“在线"生产服务环境中拥有 5 台服务器.这允许你让 1 个服务器
..
我正在使用 zookeeper 从 kafka 获取数据.在这里我总是从最后一个偏移点获取数据.有什么办法可以指定偏移时间来获取旧数据吗? 有一个选项 autooffset.reset.它接受最小或最大.有人可以解释什么是最小和最大.autooffset.reset 可以帮助从旧偏移点而不是最新偏移点获取数据吗? 解决方案 消费者始终属于一个组,对于每个分区,Zookeeper 会跟
..
我正在使用 zookeeper 从 kafka 获取数据.在这里,我总是从最后一个偏移点获取数据.有什么办法可以指定偏移时间来获取旧数据吗? 有一个选项 autooffset.reset.它接受最小或最大.有人可以解释什么是最小和最大.autooffset.reset 可以帮助从旧偏移点而不是最新偏移点获取数据吗? 解决方案 消费者始终属于一个组,对于每个分区,Zookeeper 会
..
来自 ZooKeeper常见问题解答: Reliability: A single ZooKeeper server (standalone) is essentially a coordinator with no reliability (a single serving node failure brings down the ZK service). A 3 server ens
..
我正在使用Zookeeper从kafka获取数据.在这里,我总是从最后一个偏移点获取数据.有什么方法可以指定获取旧数据的偏移时间吗? 有一个选项autooffset.reset.它接受最小或最大.有人可以解释什么是最小的和最大的. autooffset.reset可以帮助从旧的偏移点而不是最新的偏移点获取数据吗? 解决方案 使用者始终属于一个组,对于每个分区,Zookeeper都会跟
..
,如果所示,我在本地搭建hbase,使用的是外部的本地自己搭建的zookeeper集群(非自带的),并且hbase_manages_zk设置为false,然后一切组建启动正常,但是我在另一台机器上通过java hbase client程序去读取数据,出现程序阻塞的现象,最后发现zookeeper集群中的/hbase下面的节点内容都为空,就如图中红色的方框圈出的所以。 以下是我的机器启动后的各个节
..
问 题 网上找到的都是linux下的php扩展,windows没有吗? 解决方案 如果你在 http://pecl.php.net/ 和 github 上都没有找到,那么估计就是没有了 很多扩展都是不支持 win 的,建议可以本地起个虚拟机 or docker 开发
..
问 题 执行php -m | grep zookeeper后报错 PHP Warning: PHP Startup: Unable to load dynamic library '/usr/lib64/php/modules/zookeeper.so' - libzookeeper_mt.so.2: cannot open shared object file: No such file
..
问 题 1.Kafka的消费者什么时候开启? 是随着项目的启动就开启消费者吗还是通过监听有新的消息才开启消费者? 回答问题的不要看ID,本人要脸 解决方案 你不开启你从何途径监听有新的消息?如果其他途径也可以,为什么不统一使用 Consumer 呢?结构也简单,程序也可靠,也方便分布到不同服务器。 当然了,还得看你业务了,如果你 8 百年也没来一条消息,来一条处
..
问 题 如题:Dubbo中zookeeper做注册中心,如果注册中心集群都挂掉,发布者和订阅者之间还能通信么? ================================================================================ 可以的,启动dubbo时,消费者会从zk拉取注册的生产者的地址接口等数据,缓存在本地。每次调用时,按照本地存储的
..
问 题 public T readData(java.lang.String path, org.apache.zookeeper.data.Stat stat) 这个方法的作用是什么?为什么要有第二个参数stat? 解决方案 把path节点的Stat数据拷贝到参数stat中。因为java中方法不能返回多个值,所以要这么干
..
问 题 kafka启动卡在这一行不动 [2016-11-25 17:34:26,630] INFO [Kafka Server 0], started (kafka.server.KafkaServer) kafka的启动日志如下: [root@VM_102_155_centos kafka_2.11-0.10.1.0]# bin/kafka-server-start.sh c
..
问 题 我知道选举需要过半数,但是如果有5个节点,当leader挂掉之后,不是剩下4个节点,又变回偶数了么??? 解决方案 所谓的zookeeper容错是指,当宕掉几个zookeeper服务器之后,剩下的个数必须大于宕掉的个数,也就是剩下的服务数必须大于n/2,zookeeper才可以继续使用,无论奇偶数都可以选举leader。5台机器最多宕掉2台,还可以继续使用,因为剩下3台大
..
我安装了Cassandra群集和Zookeeper服务器。现在我想使用zookeeper支持cassandra中的事务。我怎么做。 Zookeeper创建znode以执行读取和写入操作,数据来回Zookeeper中的znode。我想知道如何支持回滚和提交功能在cassandra使用Zookeeper。是否有任何方式,我们可以在zookeeper或zookeeper配置cassandra中指定
..
我在一个系统上工作,我需要在Cassandra数据库中存储Avro Schemas。因此,在Cassandra中,我们将存储如下 SchemaId AvroSchema 1一些模式 2另一个模式 现在假设在Cassandra中插入另一行表格如下 - SchemaId AvroSchema 1一些模式 2另一个模式 3另一个新架构
..
一个问题,我面对supervisord是,当我有一个命令这反过来又产生另一个过程,supervisord无法杀死它。 例如我有一个正常运行的时候就像一个Java进程 $ zkServer.sh启动前景 $ PS -eaf | grep的ZK 用户30404 28280 0 09:21分/ 2 00:00:00庆典zkServer.sh启动前景 用户30413 30404 76 09:2
..
有关于Solr的认证和放几个主题和文章;授权,但我不能得到它的工作(我喜欢的方式)。 我跟着这些教程/信息来源: 的https://cwiki.apache.org/confluence/display/solr/Authentication+and+Authorization+Plugins 和 的https://lucidworks.com/blog/2015/08/17/securi
..
我有关于延迟基准的问题。我在5台机器(一个领导者,其余都是追随者)的集群运行Apache ZooKeeper的。有用于测序请求发送到协议另一个机(客户端)。 我管理运行一个基准程序,持续pre-选定的时间,目的是同时并连续请求发送到每个服务器的ZooKeeper。当pre-选择的时间后,我可以看到延迟的结果。 但是,在上述基准仅使用一个客户机运行基准code。现在,我想增加客户机的数量,使更多
..
(我在CentOS 5.8上运行)。我一直在下面的群集(多服务器)动物园管理员建立的方向,但得到一个错误,当我尝试启动我的服务器。当我运行命令的文档中描述: java命令饲养员-3.4.6.jar:LIB /的log4j-1.2.16.jar:CONF \\ org.apache.zookeeper.server.quorum.QuorumPeerMain的conf /动物园。 CFG 我
..
我正在学习有关动物园管理员。我学会了当集群中含有机1000的那个饲养员是非常有用的。我有几个疑问。 我试着阅读下面的链接了解 解释的Apache ZooKeeper的结果 解释的Apache ZooKeeper的 我有以下几个问题 1)在如何处理集群上千台机器时,动物园管理员是有帮助吗?结果 2)如何解决饲养员分布式同步问题?结果 3)究竟是如何解决的动物园管理员集中配置的问题?
..