如何配置多节点Apache Storm集群
我正在关注 http://jayatiatblogs.blogspot.com/2011/11/storm-installation.html &http://zookeeper.apache.org/doc/r3.3.3/zookeeperAdmin.html#sc_zkMulitServerSetup 在 AWS EC2 的 Ubuntu 14.04 LTS 中设置 Apache Storm
..
apache-zookeeper相关内容
Zookeeper CLI 失败 - IOException 数据包 超出范围
运行zookeeper 3.3.3.我有一个 znode，我只是想通过 CLI 列出它，如下所示: ls/myznode/subznode 第 710 行的 org.apache.ClientCnxn$SendThread.readLength 中的 IOException 导致崩溃. 有人看到了吗??有人建议可能坏数据在 znode 中.不确定是否或如何......但我也无法删
..
未在日志目录中创建 zookeeper.log 文件
我无法在我在 log4j.properties 中指定的目录下创建 zookeeper.log.我不确定出了什么问题，有人可以指导我解决这个问题吗? 请在下面找到 log4j.properties 文件. zookeeper.root.logger= INFO, ROLLINGFILEzookeeper.console.threshold=信息zookeeper.log.dir=/usr/
..
Zookeeper 数据目录清理
我正在运行 3 节点 zookeeper 集群来处理 Storm 和 kafka.Zookeeper 数据目录占用了我系统中的所有空间.我不知道如何清理它.因为，我不想完全删除数据因为我会丢失进程的状态.我查看了 zoo.cfg 中的 autopurge.purgeInterval，但它没有按我预期的那样工作. 我使用的是zookeeper 3.4.6 如何在不影响新数据的情况下删除旧
..
Kafka 在某些节点上分区不同步
我正在 3 个 EC2 实例上运行 Kafka 集群.每个实例运行 kafka (0.11.0.1) 和 zookeeper (3.4).我的主题配置为每个主题有 20 个分区，ReplicationFactor 为 3. 今天我注意到有些分区拒绝同步到所有三个节点.举个例子: bin/kafka-topics.sh --zookeeper "10.0.0.1:2181,10.0.0.2:
..
Apache Kafka:无法更新元数据/java.nio.channels.ClosedChannelException
我刚刚开始使用 Apache Kafka/Zookeeper，在尝试在 AWS 上设置集群时遇到了问题.目前我有三台服务器: 一个运行 Zookeeper，两个运行 Kafka. 我可以毫无问题地启动 Kafka 服务器，并且可以在这两个服务器上创建主题.但是，当我尝试在一台机器上启动生产者并在另一台机器上启动消费者时，麻烦就来了: 关于卡夫卡制作人: kafka-consol
..
Zookeeper 管理服务器端口
在 windows 上安装了 zookeeper 3.5.6 bin.获取错误:无法启动AdminServer，异常退出org.apache.zookeeper.server.admin.AdminServer$AdminServerException:在地址 0.0.0.0、端口 8080 和命令 URL/commands 上启动 AdminServer 时出现问题 我在哪里可以找到 Adm
..
如果zookeeper.set.acl 设置为true，Kafka 不会启动
我设置了 kerberized Zookeeper 和 kerberized Kafka，它们在 zookeeper.set.acl 设置为 false 时工作正常.当我尝试在参数设置为 true 的情况下启动 Kafka 时，我在 Zookeeper 日志中得到了这个: Nov 12 13:36:26 docker:zookeeper_corelinux_[1195]: [2
..
Kafka 0.8中producer能不能找到broker的增删改查?
我们知道，在kafka 0.7中，我们可以为producer指定zk.connect，这样producer可以找到broker的增删.但是在 kafka 0.8 中，我们不能为生产者指定 zk.connect.kafka 0.8 中的生产者能找到吗?如果不是，系统的扩展性不比0.7版本差? 解决方案 您仍然可以使用 ZooKeeper 客户端来检索代理列表: ZkClient zkCli
..
连接到 Apache Kafka 多节点集群中的 Zookeeper
我按照以下说明设置了多节点 kafka 集群.现在，如何连接到zookeeper?可以在 JAVA 中从生产者/消费者端连接到一个动物园管理员还是有办法连接所有动物园管理员节点? 设置多节点Apache ZooKeeper集群 在集群的每个节点上，将以下几行添加到文件 kafka/config/zookeeper.properties server.1=zNode01:2888:3
..
Servicemix 4、DOSGi 和 Zookeeper
这是从 fusesource 论坛 和 servicemmix 论坛. 我无法在 FUSE 中使用 DOSGi.我正在尝试将 CXF 的 DOSGi 1.1-SNAPSHOT 与 Zookeeper 发现连接到 FUSE 4.1.0.2.我也在使用 Zookeepr 3.2.1. 在 Felix 2.0.0 上一切正常.我只是按照 DOSGi Discovery 页面上的说明进行操作，
..
配置 Druid 在 5181 端口连接到 Zookeeper
我正在运行一个 MapR 集群，想用 Druid 进行一些时间序列分析.MapR 为 Zookeeper 使用了一个非标准端口(端口 5181 而不是传统的端口 2181). 当我启动 Druid 协调器服务时，它尝试在常规 Zookeeper 端口上连接并失败: 2015-03-03T17:46:49,614 INFO [main-SendThread(localhost:2181)]
..
Curator 何时以及为何抛出 ConnectionLossException?
我使用 Curator 1.2.4，当我想监视一个 znode 的子节点更改时，我不断收到 ConnectionLossException. 然后我实现了一个这样的观察者 公共类 CuratorChildWatcherImpl 实现 CuratorWatcher {私人 CuratorFramework 客户端；公共 CuratorChildWatcherImpl(CuratorFrame
..
Zookeeper 未启动，nohup 错误
我已经下载了zookeeper-3.4.5.tar.gz，解压后我把conf/zoo.cfg写成 tickTime=2000数据目录=/var/zookeeper客户端端口=2181 现在我尝试通过 bin/zkServer.sh start 启动zookeeper它给 mohit@mohit:~/zookeeper-3.4.5/bin$ sudo sh zkServer.sh start[
..
如何监控Kafka消息的应用程序处理进行负载测试
有一个应用程序(不是我的)从 Kafka 读取消息，对它们进行一些处理，并将记录存储在数据库中.我已经用 Java 编写了一个程序，该程序以给定的速率将消息写入队列.现在，它通过在测试运行结束时查询数据库来执行简单的性能测量，以确保记录输入 = 记录输出.但是，我想扩展它以定期检查队列以查看应用程序尚未处理的待处理消息数量，以查看它是否正在备份. 我认为我可以在 Zookeeper 中检查应
..
我如何在zookeeper zkServer.cmd 中启用带有端口的远程jmx
这里是我的 zkServer.cmd 文件: @echo off设置本地调用“%~dp0zkEnv.cmd"设置 ZOOMAIN=org.apache.zookeeper.server.quorum.QuorumPeerMain回声调用 %JAVA% "-Dzookeeper.log.dir=%ZOO_LOG_DIR%" "-Dzookeeper.root.logger=%ZOO_LOG4J_P
..
Hortonworks HDP Sandbox 上的 HBase:无法从 ZooKeeper 获取主地址
我从 hortonworks 为 virtualbox 下载了 HDP 2.1.在使用 Hbase shell 的情况下使用简单命令时出现以下错误:create 't1', {NAME=> 'f1', VERSIONS => 5} Hortonworks “错误:无法从 ZooKeeper 获取主地址；znode 数据 == 空" 我需要做什么才能让 hbase 在这个沙盒环境中工作?
..
连接并持久化到 HBase
我只是尝试使用 java 客户端连接到 hbase，它是 cloudera-vm 的一部分. (192.168.56.102 是虚拟机的 inet ip) 我使用只有主机网络设置的虚拟机. 这样我就可以访问hbase master的webUI@http://192.168.56.102:60010/master.jsp 我的 java 客户端(在 vm 本身上运行良好)也建
..
2n + 1 法定人数是什么意思?
我在描述 HBase 的 Zookeeper 配置时遇到过这个，我不熟悉这个术语.“N"是否与我的 HBase 集群中的节点数量有关?或者我应该在我的 Zookeeper 集群中使用多少节点? 解决方案 2f+1 指的是你需要的可靠性/可用性级别，一般来说它与性能无关. ZooKeeper 集成(服务集群)由一台或多台服务器组成，这些服务器对每次更改进行“投票".大多数原始服务器在接
..
在 Amazon EMR 上从 java 使用 hbase 时遇到问题
所以我尝试使用我作为 MapReduce 步骤启动的自定义 jar 在 Amazon ec2 上查询我的 hbase 集群.我是我的 jar(在 map 函数内)我这样调用 Hbase: public void map( Text key, BytesWritable value, Context contex ) throws IOException, InterruptedException
..