【赵渝强老师】Kafka分区的副本机制原创

本节课我们来讨论一下kaf克中分区的副本机制。在这里的kaf克集群中有三个broker，分别是BROKER0、BROKER1和BROKER2。创建一个名叫my topic的主题，它有两个分区P0和P1，并且每个分区都有三个副本，这些副本都位于不同的broker上。在屏幕下方展示了创建该topic时所使用到的命令。在分区的这三个副本中，其中一个副本的角色是leader，例如P0分区的leader位于BROKER0上，P1分区的leader位于BROKER2上，其他的分区副本角色则是follow了。当Leader所在的broker出现问题或者宕机时，Kafka会从is SR列表中顺序选举一个follow war作为该分区新的leader，这一点将会在稍后做详细介绍。由于Leader分区所在的broker负责该分区的读写操作，因此当生产者producer把消息数据写入P0分区时，会由BROKER0来执行写入数据的操作。一旦消息数据。

写入成功follow war将会从leader上同步最新写入的消息数据。当生产者producer网分区P1上写入消息数据时，也是按照同样的方式。前面提到，当leader所在的broker出现问题或者宕机时，CF car会从is SR列表中顺序选举一个follow war作为该分区新的leader。这里可以通过执行相应的命令查看topic的详细信息来进行说明。通过Describe命令输出的信息可以看出，P0分区的leader目前位于BROKER0上，P1分区的leader目前位于BROKER2上，Isr列表中则记录选举的规则isrhiing sinc repplica的缩写。以P0分区为例进行说明。当BROKER0出现问题时，Kafca则会选择BROKER1作为P0分区新的leader。如果R1再出现问题，Kafka则会选择BROKEER2作为P0分区新的leader，通过这样的方式，Kafka实现了分区的高可用功能。现在你已经知道kafka。

中分区的副本机制了，那你知道CF课的主题topic和分区partition的关系吗？欢迎评论区留言讨论好了，记得点加号关注赵宇强老师。