安装Zookeeper和Kafka集群本文介绍如何安装Zookeeper和Kafka集群。为了方便，介绍的是在一台服务器上的安装，实际应该安装在多台服务器上，但步骤是一样的。安装Zookeeper集群下载安装包从官网上下载安装包：curlhttps://dlcdn.apache.org/zookeeper/zookeeper-3.7.1/apache-zookeeper-3.7.1-bin.tar.gz-oapache-zookeeper-3.7.1-bin.tar.gz解压：tarxvfapache-zookeeper-3.7.1-bin.tar.gz配置创建目录zk1，然后添加如下配置：z
前言最近在搭建Hbase服务时，服务无法启动，于是决定将hbase服务删除，在当删除zookeeper的/hbase节点时报错，报thenticationisnotvalid:/hbase/tokenauth。看到网上大部分的文章都是使用跳过ACL或者开启super模式这两种方式，于是比较好奇有没有第三种解，这里整理并记录一下。版本zookeeper3.4.8CDP7.1.7（同CDH）问题复现zookeeper-client-server`hostname`:2181rmr/hbaseAuthenticationisnotvalid:/hbase/tokenauth解决方案这里将三种方式都列
文章目录一、zookeeper1.zookeeper的概述1.1Zookeeper定义1.2Zookeeper工作机制1.3Zookeeper特点1.4Zookeeper数据结构1.5Zookeeper应用场景1.6Zookeeper选举机制第一次启动选举机制非第一次启动选举机制选举Leader规则2.部署Zookeeper集群2.1安装前准备2.2安装Zookeeper二、Kafka1.消息队列概述1.1为什么需要消息队列（MQ）1.2使用消息队列的好处1.3消息队列的两种模式2.Kafka概述2.1Kafka定义2.2Kafka简介2.3Kafka的特性2.4Kafka系统架构Broker
前言本人是才学完大数据的无业游民，我将会总结学习收获或发表自己的学习心得，期望给初学者也为自己今后复习提供一些帮助。我将陆续发布大数据阶段所学，包括但不限于（hadoop，hive，hbase，phoneix，flume，bdeaver，kafka，spark，kylin，flink，azkaban）。为了减少犯错，我在写下自己的博客时，会查阅官方文档或类似文章，也会将出处标记于文章末尾。如果你是一名初学者，有学习问题可以联系我，或许你将做的决定和会犯的错我也经历过。我们互相督促，共同进步吧！目录一、引入1.zookeeper是什么2.zookeeper能做什么3.zookeeper优势是什么
Zookeeper的搭建方式单机模式单机伪集群模式⼀台服务器上运⾏多个Zookeeper实例；集群模式Zookeeper运⾏于⼀个集群上，适合⽣产环境，这个计算机集群被称为⼀个“集合体”如果在分布式的生产环境中使用ZooKeeper，推荐使用大于3的奇数节点个数搭建集群，这样能提升系统的可用性。集群模式、伪集群模式安装方式都差不多只是真正的集群模式需要使用不同的IP。单机模式则更简单了，只需要取消掉zoo.cfg配置文件中的集群配置就行。二、伪集群模式安装Zookeeper官网下载安装包官网地址：https://zookeeper.apache.org/下载页面：https://zookeep
报错信息INFO[main-SendThread(localhost:12181):ClientCnxn$SendThread@959]-Socketconnectionestablished,initiatingsession,client:/xxxxxx:38806,server:localhost/xxxxx:12181INFO[main-SendThread(localhost:12181):ClientCnxn$SendThread@1240]-Unabletoreadadditionaldatafromserversessionid0x0,likelyserverhasclosed
1.前言本文章是笔主在声哥的手写RPC框架的学习下，对注册中心的一个拓展。因为声哥某些部分没有保留拓展性，所以本文章的项目与声哥的工程有部分区别，核心内容在Curator的注册发现与注销，思想看准即可。本文章Git仓库：zko0/zko0-rpc声哥的RPC项目写的确实很详细，跟学一遍受益匪浅：何人听我楚狂声的博客在声哥的项目里使用Nacos作为了服务注册中心。本人拓展添加了ZooKeeper实现服务注册。Nacos的服务注册和发现，设计的不是非常好，每次服务的发现都需要去注册中心拉取。本人实现ZooKeeper注册中心时，参考了Dubbo的设计原理，结合本人自身想法，添加了本地缓存：Clie
下载zookeeper下载地址：https://zookeeper.apache.org/releases.html选择ApacheZooKeeper3.8.0(asc,sha512)点击https://dlcdn.apache.org/zookeeper/zookeeper-3.8.0/apache-zookeeper-3.8.0-bin.tar.gz完成下载。配置文件修改apache-zookeeper-3.8.0\conf目录下的zoo-simple.cfg文件为zoo-simple.cfg，修改文件内容：#指定缓存路径dataDir=D:\\home\apache-zookeeper-
java操作zookeeper创建一个maven项目在pom文件里引入如下依赖：junitjunit4.10testorg.apache.curatorcurator-framework4.0.0org.apache.curatorcurator-recipes4.0.0org.slf4jslf4j-api1.7.21org.slf4jslf4j-log4j121.7.21创建一个测试类进行相关操作的测试连接客户端@BeforepublicvoidtestConnect(){ExponentialBackoffRetryretryPolicy=newExponentialBackoffRetr
1.下载Zookper官网下载地址2.上传文件到指定目录上传方法点击链接mkdir/usr/local/src/zookeeper3.在指定文件下解压文件tar-zxvfapache-zookeeper-3.7.1-bin.tar.gz4.配置zookpercd/usr/local/src/zookeeper/conf//切换到该目录cpzoo_sample.cfgzoo.cfg//复制一份取名为zoo.cfgmvzoo_sample.cfgzoo.cfgmkdirdata//创建data的存储数据保存data的存储路径，在config文件中进行修改/usr/local/src/zookeep
