通过kafka处理1.下载；重新进行ansibleplaybookbootstrap.yml两个pump和drainer在下载的resource/bin/下面。拷贝到deploy/bin/目录下。1.修改inventory.ini设置enable\_binlogTrue设置zk地址，不然会报错，一定需要zk注

!(https://oscimg.oschina.net/oscnet/2752fc97a29741f9b8cf1f6627079e8a.png)自我保护背景首先对Eureka注册中心需要了解的是Eureka各个节点都是平等的，没有ZK中角色的概念，即使N1个节点挂掉也不会影响其他节点的正常运行。默认情况

etcd的使用文章。etcd来zookeeper类似，常用的主要有set，get，getPrefix：获取指定前缀的所有数据，grant：key的超时设置，watch：监听回调事件，watchPrefix：监听某个前缀的事件，keepAlive：为某个key设置自动续约、自动刷新过期时间。zk的大部分功能，etcd都有。但有一个，譬如虚拟节点，zk可

DUBBO是一个分布式服务框架，从本章开始，我们由浅入深，先体验再实战，逐步入门dubbo服务的开发、部署和调用，本章的目标是以最快的速度体验dubbo服务；启动容器创建一个dockercompose.yml文件，内容如下：version:'2'services:zk_server:

搭建准备：zookeeper是一定要提前安装好的，并最先启动运行！另外，强烈推荐安装ZKUI和dubboadmin：zkui可以实时查看zk的最新配置，和检测节点变化时代码的实时同步更新dubboadmin可以检测你的provider或者consumer有没有正确连接上，和consumer是否正确调用到了providerdubb

自我保护背景首先对Eureka注册中心需要了解的是Eureka各个节点都是平等的，没有ZK中角色的概念，即使N1个节点挂掉也不会影响其他节点的正常运行。默认情况下，如果EurekaServer在一定时间内（默认90秒）没有接收到某个微服务实例的心跳，EurekaServer将会移除该实例。但是当网络分区故障发生时，微服务与EurekaSer

在系统平稳运行一年的基础上，为提供更好的服务，现针对java，kafka，flume，zk,统一进行版本升级，请各位小伙伴跟着走起来，不要掉队啊！名称老版本号新版本号jdk1.7.0\_251.8.0kafka2.100.8.0.12.100.10.2.1flume1.6.01.7.0zookeeper

升级原理。就是将fabric的zk,kafka,orderer,peer(我只用的这4个)升级到最新版本；且这几个容器的关键生产数据使用volume簇放置在外面。可以参考《区块链原理、设计与应用(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fwww.gitbook.com%2Fbook

现在市面上有各式各样的分布式定时任务，每个都有其独特的特点，我们这边的项目因为一开始使用的是分布式开源调度框架TBSchedule，但是这个框架依赖ZK，由于ZK的不稳定性和项目老旧无人维护，导致我们的定时任务会偶发出现异常,比如：任务停止、任务项丢失、任

1、概念Kafka是最初由Linkedin公司开发，是一个分布式、支持分区的（partition）、多副本的（replica）分布式消息系统（kafka2.8.0版本之后接触了对zk的依赖，使用自己的kRaft做集群管理，新增内部主体@metadata存储