9张图,Kafka为什么要放弃Zookeeper ?

沙海 2021年5月21日10:14:16Java评论75字数 4655阅读15分31秒阅读模式
摘要

速读摘要

速读摘要文章源自JAVA秀-https://www.javaxiu.com/24535.html

之前部署Kafka就必须得部署Zookeeper,而之后就只要单独部署Kafka就行了。Apache Kafka最早是由Linkedin公司开发,后来捐献给了Apack基金会。在大规模集群和云原生的背景下,使用Zookeeper给Kafka的运维和集群性能造成了很大的压力。最后给大家送下福利,大家可以关注Java后端编程公众号,在后台回复"Java"可以获取一份我整理的最新Java面试题资料。文章源自JAVA秀-https://www.javaxiu.com/24535.html

原文约 2773 | 图片 13 | 建议阅读 6 分钟 | 评价反馈文章源自JAVA秀-https://www.javaxiu.com/24535.html

9张图,Kafka为什么要放弃Zookeeper ?

程序IT圈 文章源自JAVA秀-https://www.javaxiu.com/24535.html

以下文章来源于程序员jinjunzhu,作者jinjunzhu文章源自JAVA秀-https://www.javaxiu.com/24535.html

文章源自JAVA秀-https://www.javaxiu.com/24535.html

9张图,Kafka为什么要放弃Zookeeper ?文章源自JAVA秀-https://www.javaxiu.com/24535.html

程序员jinjunzhu文章源自JAVA秀-https://www.javaxiu.com/24535.html

资深后端开发,擅长java/golang,关注后端开发、分布式、云原生领域文章源自JAVA秀-https://www.javaxiu.com/24535.html

文章源自JAVA秀-https://www.javaxiu.com/24535.html

最近,confluent社区发表了一篇文章,主要讲述了Kafka未来的2.8版本将要放弃Zookeeper,这对于Kafka用户来说,是一个重要的改进。之前部署Kafka就必须得部署Zookeeper,而之后就只要单独部署Kafka就行了。[1]文章源自JAVA秀-https://www.javaxiu.com/24535.html

1.Kafka简介

Apache Kafka最早是由Linkedin公司开发,后来捐献给了Apack基金会。文章源自JAVA秀-https://www.javaxiu.com/24535.html

Kafka被官方定义为分布式流式处理平台,因为具备高吞吐、可持久化、可水平扩展等特性而被广泛使用。目前Kafka具体如下功能:文章源自JAVA秀-https://www.javaxiu.com/24535.html

  • 消息队列,Kafka具有系统解耦、流量削峰、缓冲、异步通信等消息队列的功能。文章源自JAVA秀-https://www.javaxiu.com/24535.html

  • 分布式存储系统,Kafka可以把消息持久化,同时用多副本来实现故障转移,可以作为数据存储系统来使用。文章源自JAVA秀-https://www.javaxiu.com/24535.html

  • 实时数据处理,Kafka提供了一些和数据处理相关的组件,比如Kafka StreamsKafka Connect,具备了实时数据的处理功能。文章源自JAVA秀-https://www.javaxiu.com/24535.html

下面这张图是Kafka的消息模型:[2]文章源自JAVA秀-https://www.javaxiu.com/24535.html

9张图,Kafka为什么要放弃Zookeeper ?文章源自JAVA秀-https://www.javaxiu.com/24535.html

通过上面这张图,介绍一下Kafka中的几个主要概念:文章源自JAVA秀-https://www.javaxiu.com/24535.html

  • producerconsumer: 消息队列中的生产者和消费者,生产者将消息推送到队列,消费者从队列中拉取消息。文章源自JAVA秀-https://www.javaxiu.com/24535.html

  • consumer group:消费者集合,这些消费者可以并行消费同一个topic下不同partition中的消息。文章源自JAVA秀-https://www.javaxiu.com/24535.html

  • brokerKafka集群中的服务器。文章源自JAVA秀-https://www.javaxiu.com/24535.html

  • topic:消息的分类。文章源自JAVA秀-https://www.javaxiu.com/24535.html

  • partitiontopic物理上的分组,一个topic可以有partition,每个partition中的消息会被分配一个有序的id作为offset。每个consumer group只能有一个消费者来消费一个partition文章源自JAVA秀-https://www.javaxiu.com/24535.html

2.Kafka和Zookeeper关系

Kafka架构如下图:9张图,Kafka为什么要放弃Zookeeper ?从图中可以看到,Kafka的工作需要Zookeeper的配合。那他们到底是怎么配合工作呢?文章源自JAVA秀-https://www.javaxiu.com/24535.html

看下面这张图:9张图,Kafka为什么要放弃Zookeeper ?文章源自JAVA秀-https://www.javaxiu.com/24535.html

2.1 注册中心

2.1.1 broker注册

从上面的图中可以看到,broker分布式部署,就需要一个注册中心来进行统一管理。Zookeeper用一个专门节点保存Broker服务列表,也就是 /brokers/ids文章源自JAVA秀-https://www.javaxiu.com/24535.html

broker在启动时,向Zookeeper发送注册请求,Zookeeper会在/brokers/ids下创建这个broker节点,如/brokers/ids/[0...N],并保存brokerIP地址和端口。文章源自JAVA秀-https://www.javaxiu.com/24535.html

文章源自JAVA秀-https://www.javaxiu.com/24535.html

这个节点临时节点,一旦broker宕机,这个临时节点会被自动删除。文章源自JAVA秀-https://www.javaxiu.com/24535.html

文章源自JAVA秀-https://www.javaxiu.com/24535.html

2.1.2 topic注册

Zookeeper也会为topic分配一个单独节点,每个topic都会以/brokers/topics/[topic_name]的形式记录在Zookeeper文章源自JAVA秀-https://www.javaxiu.com/24535.html

一个topic的消息会被保存到多个partition,这些partitionbroker的对应关系也需要保存到Zookeeper文章源自JAVA秀-https://www.javaxiu.com/24535.html

partition是多副本保存的,上图中红色partitionleader副本。当leader副本所在的broker发生故障时,partition需要重新选举leader,这个需要由Zookeeper主导完成。文章源自JAVA秀-https://www.javaxiu.com/24535.html

broker启动后,会把自己的Broker ID注册到到对应topic节点的分区列表中。文章源自JAVA秀-https://www.javaxiu.com/24535.html

我们查看一个topicxxx,分区编号是1的信息,命令如下:文章源自JAVA秀-https://www.javaxiu.com/24535.html

[root@master] get /brokers/topics/xxx/partitions/1/state{"controller_epoch":15,"leader":11,"version":1,"leader_epoch":2,"isr":[11,12,13]}

文章源自JAVA秀-https://www.javaxiu.com/24535.html

broker退出后,Zookeeper会更新其对应topic的分区列表。文章源自JAVA秀-https://www.javaxiu.com/24535.html

文章源自JAVA秀-https://www.javaxiu.com/24535.html

2.1.3 consumer注册

消费者组也会向Zookeeper进行注册,Zookeeper会为其分配节点来保存相关数据,节点路径为/consumers/{group_id},有3个子节点,如下图:9张图,Kafka为什么要放弃Zookeeper ?这样Zookeeper可以记录分区跟消费者的关系,以及分区的offset[3]文章源自JAVA秀-https://www.javaxiu.com/24535.html

2.2 负载均衡

brokerZookeeper进行注册后,生产者根据broker节点来感知broker服务列表变化,这样可以实现动态负载均衡。文章源自JAVA秀-https://www.javaxiu.com/24535.html

consumer group中的消费者,可以根据topic节点信息来拉取特定分区的消息,实现负载均衡。文章源自JAVA秀-https://www.javaxiu.com/24535.html

文章源自JAVA秀-https://www.javaxiu.com/24535.html

实际上,KafkaZookeeper中保存的元数据非常多,看下面这张图:9张图,Kafka为什么要放弃Zookeeper ?随着broker、topic和partition增多,保存的数据量会越来越大。文章源自JAVA秀-https://www.javaxiu.com/24535.html

文章源自JAVA秀-https://www.javaxiu.com/24535.html

3.Controller介绍

经过上一节的讲述,我们看到了KafkaZookeeper的依赖非常大,Kafka离开Zookeeper是没有办法独立运行的。那Kafka是怎么跟Zookeeper进行交互的呢?文章源自JAVA秀-https://www.javaxiu.com/24535.html

如下图:[4]9张图,Kafka为什么要放弃Zookeeper ?Kafka集群中会有一个broker被选举为Controller负责跟Zookeeper进行交互,它负责管理整个Kafka集群中所有分区和副本的状态。其他broker监听Controller节点的数据变化。文章源自JAVA秀-https://www.javaxiu.com/24535.html

Controller的选举工作依赖于Zookeeper,选举成功后,Zookeeper会创建一个/controller临时节点。文章源自JAVA秀-https://www.javaxiu.com/24535.html

Controller具体职责如下:文章源自JAVA秀-https://www.javaxiu.com/24535.html

  • 监听分区变化文章源自JAVA秀-https://www.javaxiu.com/24535.html

文章源自JAVA秀-https://www.javaxiu.com/24535.html

比如当某个分区的leader出现故障时,Controller会为该分区选举新的leader。当检测到分区的ISR集合发生变化时,Controller会通知所有broker更新元数据。当某个topic增加分区时,Controller会负责重新分配分区。文章源自JAVA秀-https://www.javaxiu.com/24535.html

文章源自JAVA秀-https://www.javaxiu.com/24535.html

  • 监听topic相关的变化文章源自JAVA秀-https://www.javaxiu.com/24535.html

  • 监听broker相关的变化文章源自JAVA秀-https://www.javaxiu.com/24535.html

  • 集群元数据管理文章源自JAVA秀-https://www.javaxiu.com/24535.html

下面这张图展示了Controller、Zookeeper和broker的交互细节:9张图,Kafka为什么要放弃Zookeeper ?Controller选举成功后,会从Zookeeper集群中拉取一份完整的元数据初始化ControllerContext,这些元数据缓存在Controller节点。当集群发生变化时,比如增加topic分区,Controller不仅需要变更本地的缓存数据,还需要将这些变更信息同步到其他Broker文章源自JAVA秀-https://www.javaxiu.com/24535.html

Controller监听到Zookeeper事件、定时任务事件和其他事件后,将这些事件按照先后顺序暂存到LinkedBlockingQueue中,由事件处理线程按顺序处理,这些处理多数需要跟Zookeeper交互,Controller则需要更新自己的元数据。文章源自JAVA秀-https://www.javaxiu.com/24535.html

4.Zookeeper带来的问题

Kafka本身就是一个分布式系统,但是需要另一个分布式系统来管理,复杂性无疑增加了。文章源自JAVA秀-https://www.javaxiu.com/24535.html

4.1 运维复杂度

使用了Zookeeper,部署Kafka的时候必须要部署两套系统,Kafka的运维人员必须要具备Zookeeper的运维能力。文章源自JAVA秀-https://www.javaxiu.com/24535.html

4.2 Controller故障处理

Kafaka依赖一个单一Controller节点跟Zookeeper进行交互,如果这个Controller节点发生了故障,就需要从broker中选择新的Controller。如下图,新的Controller变成了broker3文章源自JAVA秀-https://www.javaxiu.com/24535.html

9张图,Kafka为什么要放弃Zookeeper ?文章源自JAVA秀-https://www.javaxiu.com/24535.html

新的Controller选举成功后,会重新从Zookeeper拉取元数据进行初始化,并且需要通知其他所有的broker更新ActiveControllerId。老的Controller需要关闭监听、事件处理线程和定时任务。分区数非常多时,这个过程非常耗时,而且这个过程中Kafka集群是不能工作的。文章源自JAVA秀-https://www.javaxiu.com/24535.html

4.3 分区瓶颈

当分区数增加时,Zookeeper保存的元数据变多,Zookeeper集群压力变大,达到一定级别后,监听延迟增加,给Kafaka的工作带来了影响。文章源自JAVA秀-https://www.javaxiu.com/24535.html

所以,Kafka单集群承载的分区数量是一个瓶颈。而这又恰恰是一些业务场景需要的。文章源自JAVA秀-https://www.javaxiu.com/24535.html

5.升级

升级前后的架构图对比如下:文章源自JAVA秀-https://www.javaxiu.com/24535.html

9张图,Kafka为什么要放弃Zookeeper ?文章源自JAVA秀-https://www.javaxiu.com/24535.html

KIP-500Quorum Controller代替之前的ControllerQuorum中每个Controller节点都会保存所有元数据,通过KRaft协议保证副本的一致性。这样即使Quorum Controller节点出故障了,新的Controller迁移也会非常快。文章源自JAVA秀-https://www.javaxiu.com/24535.html

官方介绍,升级之后,Kafka可以轻松支持百万级别的分区。文章源自JAVA秀-https://www.javaxiu.com/24535.html

文章源自JAVA秀-https://www.javaxiu.com/24535.html

Kafak团队把通过Raft协议同步数据的方式Kafka Raft Metadata mode,简称KRaft文章源自JAVA秀-https://www.javaxiu.com/24535.html

文章源自JAVA秀-https://www.javaxiu.com/24535.html

Kafka的用户体量非常大,在不停服的情况下升级是必要的。文章源自JAVA秀-https://www.javaxiu.com/24535.html

目前去除ZookeeperKafka代码KIP-500已经提交到trunk分支,并且已经在的2.8版本发布。文章源自JAVA秀-https://www.javaxiu.com/24535.html

Kafaka计划在3.0版本会兼容Zookeeper ControllerQuorum Controller,这样用户可以进行灰度测试。[5]文章源自JAVA秀-https://www.javaxiu.com/24535.html

6.总结

在大规模集群和云原生的背景下,使用ZookeeperKafka的运维和集群性能造成了很大的压力。去除Zookeeper是必然趋势,这也符合大道至简的架构思想。文章源自JAVA秀-https://www.javaxiu.com/24535.html

Reference

[1]文章源自JAVA秀-https://www.javaxiu.com/24535.html

参考1:https://www.confluent.io/blog/kafka-without-zookeeper-a-sneak-peek/文章源自JAVA秀-https://www.javaxiu.com/24535.html

[2]文章源自JAVA秀-https://www.javaxiu.com/24535.html

参考2:https://blog.csdn.net/Zidingyi_367/article/details/110490910文章源自JAVA秀-https://www.javaxiu.com/24535.html

[3]文章源自JAVA秀-https://www.javaxiu.com/24535.html

参考3:https://www.jianshu.com/p/a036405f989c文章源自JAVA秀-https://www.javaxiu.com/24535.html

[4]文章源自JAVA秀-https://www.javaxiu.com/24535.html

参考4:https://honeypps.com/mq/kafka-controller-analysis/文章源自JAVA秀-https://www.javaxiu.com/24535.html

[5]文章源自JAVA秀-https://www.javaxiu.com/24535.html

参考5:https://mp.weixin.qq.com/s/ev6NM6hptltQBuTaCHJCQQ文章源自JAVA秀-https://www.javaxiu.com/24535.html

文章源自JAVA秀-https://www.javaxiu.com/24535.html

最后给大家送下福利,大家可以关注Java后端编程公众号,在后台回复 “Java”可以获取一份我整理的最新Java面试题资料。文章源自JAVA秀-https://www.javaxiu.com/24535.html

PS:欢迎在留言区留下你的观点,一起讨论提高。如果今天的文章让你有新的启发,欢迎转发分享给更多人。推荐阅读:谷歌发布新编程语言,专治SQL各种不服Java实现超市管理系统,包含源代码!Spring Boot 接入支付宝,实战来了!Nginx 除了负载均衡,还能做什么?SpringBoot+MyBatis+docker电商项目,附带超详细的文档!最近面试BAT,整理一份面试资料《Java面试BAT通关手册》,覆盖了Java核心技术、JVM、Java并发、SSM、微服务、数据库、数据结构等等。获取方式:关注公众号并回复 java 领取,更多内容陆续奉上。
文章源自JAVA秀-https://www.javaxiu.com/24535.html

明天见(。・ω・。)ノ♡文章源自JAVA秀-https://www.javaxiu.com/24535.html

继续阅读
速蛙云 - 极致体验,强烈推荐!!!购买套餐就免费送各大视频网站会员!快速稳定、独家福利社、流媒体稳定解锁!速度快,全球上网、视频、游戏加速、独立IP均支持!基础套餐性价比很高!这里不多说,我一直正在使用,推荐购买:https://www.javaxiu.com/59919.html
weinxin
资源分享QQ群
本站是JAVA秀团队的技术分享社区, 会经常分享资源和教程; 分享的时代, 请别再沉默!
沙海
匿名

发表评论

匿名网友 填写信息

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定