
文章插图
- Leader Replica开始向Follower Replica同步消息,同步速率不同,Follower1的两条消息2和3已经同步完成,而Follower2只同步了一条消息2 。此时,Leader和Follower1的LEO都是4,而Follower2的LEO是3,HW表示已成功同步的最小偏移量,值是3,表示此时消费者只能读到0、1、2,三条消息 。

文章插图
- 所有消息都同步完成,三个副本的LEO都是4,HW也是4,消费者可以读到0、1、2、3,四条消息 。

文章插图
5. 消费者组Kafka为了提高消息的处理效率,引入了消费者组的概念 。一个消费者组(Consumer Group)包含多个消费者,一个消费者组可以同时订阅多个Topic,一个Topic也可以同时被多个消费者组订阅 。
为了保证同一个Partition的消息被顺序处理,针对一个消费者组,一个Partition的消息只会交给这个消息者组的一个消费者处理 。
【超简单的Kafka架构入门指南,看这一篇就够了】

文章插图
6. 总结本文简单介绍了Kafka架构,以及架构中涉及到底的一些名词概念,包括Producer(生产者)、Consumer(消费者)、Broker(代理节点)、Topic(主题)、Partition(分区)、Leader Replica(领导者副本)、Follower Replica(跟随者副本)、LEO(Log End Offset,日志结束偏移量)、HW(High Watermark,高水位)、Consumer Group(消费者组)等 。
推荐阅读
- 你还在用老旧的Java语法吗?Lambda表达式让你的代码更简洁!
- 采集加密网页内容的10个技巧
- OA类APP的开发流程及注意事项
- 一线大厂面试的MySQL索引夺命连环15问
- 真有这么恐怖?巴菲特将AI的危险程度比作原子弹
- 巴菲特谈AI:比尔·盖茨拉着我看过 但我现在想到的却是原子弹
- 解读ChatGPT中的RLHF
- 公众号排名提升的秘密
- 怪不得手机wifi经常断网,原来是手机的2个设置没打开,涨知识了
- 用rust编写高效稳定的html爬虫
