zookeeper系列6：调优之观察者

private static final String ZkServer = "你的zookeeper地址";

https://www.cnblogs.com/swordfall/p/8667409.html 　　Zookeeper安装使用及工作原理分析 https://www.cnblogs.com/yuyijq/p/3424473.html 　　

将hadoop的hdfs-site.xml和core-site.xml配置文件软连接到HBase中，或者复制到HBase/conf下。如果出现下面问题，是zookeeper没有文件写入权限的原因。将zookeeper目录权限改为可写入。

bin/kafka-topics.sh --create --zookeeper localhost:2181 --topic test_topic --replication-factor 3 --partitions 10 --config clean

-- 与服务器安装的Zookeeper版本相同 -->. 上面的依赖放到<dependencies>标签中，下面的放到<dependencies>标签同级目录中。--SpringCloud所有依赖管理的坐标-->

最近在看关于ZK的博客，有一些感觉很不错的内容。这篇博客是我认为比较重要的内容我把它们收集起来，便于以后看：。* Leader activation ：本阶段会推选一个leader，并建立系统状态和次序，准备好发送proposal. * Active me

import org.slf4j.Logger;private static final int SESSION_TIMEOUT = 30000;logger.info("process:"+event.getType());};pri

private String zookeeperQuorum;private String clientPort;private String znodeParent;return new HbaseTemplate(conf);private Hbase

去掉JMXPORT属性，放到Kafka-Server-Start.sh. Active: failed since Tue 2019-11-19 19:06:40 CST; 26s ago

– zookeeper is not a recognized option主要原因是Kafka 版本过高，命令不存在。

bin/zkServer.sh status 查看zookeeper集群状态

清理配置目录后重启。修改完ip之后要清理node.conf

某日，ES帮会中决定选取老大统领帮会走向辉煌。(ES集群在启动时，选取集群master,按照nodeId进行排序。同时为防止分裂，需一半以上节点同意。经过一番比试，傻牛凭借一身蛮力，决战到最后，并荣获扳手腕大赛。众人拍手欢呼，单膝下跪，高呼“傻牛帮主牛批，

贴下代码，留作备用，

通过代码操作zookeeper

添加：。peerType=observer. 修改

public class DistributeLock implements Lock,Watcher {. private String lockName;private long TIMEOUT = 3000;private String curren

error是在调用zk.exists（）时抛出的。于是开始google，发现问题是原因是：new zookeeper之后，zookeeper的还没有连接好，就去调用，当然会抛错。

调用Zookeeper的构造方法来实例化一个Zookeeper。我们以一个构造方法进行一步一步的分析。+ " sessionTimeout=" + sessionTimeout + " watcher=" + wat

https://www.ibm.com/developerworks/cn/opensource/os-cn-zookeeper/