在至少有一个Leader存在的前提下,进行Zookeeper的在线增量、在线减量、在线迁移 在全过程中ZooKeeper不停止服务
Kafka是一个高性能,高容错,多副本,可复制的分布式消息系统。在整个系统中,涉及到多处选举机制,被不少人搞混,这里总结一下,本篇文章大概会从三个方面来讲解。...
什么是zookeeper?ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件。它是一个为分布式应用提...
我使用 docker-compose 来创建,新建文件夹并在文件夹下创建一个 “docker-compose.yml”,这个文件描述了具体配置如下:
最近这个 Apache Pulsar 消息中间件非常的火,号称下一代消息中件,今天,就一起来看看它到底有多牛逼?
在分布式系统中,为保证同一时间只有一个客户端可以对共享资源进行操作,需要对共享资源加锁来实现,常见有三种方式:
即所谓的配置中心,就是发布者经数据发布到ZooKeeper的一个或一系列节点上,供订阅者进行数据订阅,进而达到动态的获取数据的目的,实现配置信息的集中式管理和数据的动态更新...
上图我们看到watcher机制有三部分组成,客户端,zookeeper,watchmanager,客户端把向zookeeper注册的同时,灰板watcher存储到客户端的watcherManager中,当zookeeper服务器端触发watcher事件后,向客户端发送通知,客户端从watc...
支持正则表达式匹配Topic来进行删除,只需要将topic 用双引号包裹起来 例如: 删除以create_topic_byhand_zk为开头的topic;
移动时代、5G时代、物联网时代的大幕已经开启,新时代提升了对Java应用的高性能、高并发的要求,也抬升了Java工程师的技术台阶和面试门槛。