温馨提示:文本由机器自动转译,部分词句存在误差,以视频为准
00:00
本节课我们来讨论一下kaf课中主题topic与分区partition之间的关系。在这里,Kaf克的集群中有三个brokeer,分别是BROKEER0、BROKER1和BROKER2。主题TOPIC1有三个分区,分别是分区0、分区1和分区2,它们位于BROKER0、R1和BROKER2上,主题TOPIC2有两个分区,分别是分区0和分区1,它们位于BROKER0和BROKER1上。换一句话说,Kafka的主题topic是一个逻辑单位,它由分区partition组成,消息以topic为单位进行归类,一个分区只属于某一个主题,分区可以分布在不同的broker上,从而支持附在均衡和容错的功能。生产者Producer负责生产消息,它会将消息顺序追加到topic中每个分区的尾部,同一主题下的不同分区包含的消息不同,当消息被追加到分区尾部的时候,Brokeer会为消息分配一个特定的偏移量地址,这个地址叫做offset。例如。
01:00
图TOPIC1的分区0中的数字0、1、2和3,该地址是消息在分区中的唯一标识,且不能跨越分区。Kafka通过它来保证消息在分区中的顺序性,也就是说,Kafka保证的是分区有序而不是主题有序。现在你已经知道kafka中主题topic和分区partition的关系了,那你知道cof克分区的副本机制吗?欢迎评论区留言讨论好了,记得点加号关注赵玉强老师。
我来说两句