超简单的Kafka架构入门指南,看这一篇就够了( 二 )


超简单的Kafka架构入门指南,看这一篇就够了

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

超简单的Kafka架构入门指南,看这一篇就够了

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

超简单的Kafka架构入门指南,看这一篇就够了

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

文章插图
6. 总结本文简单介绍了Kafka架构,以及架构中涉及到底的一些名词概念,包括Producer(生产者)、Consumer(消费者)、Broker(代理节点)、Topic(主题)、Partition(分区)、Leader Replica(领导者副本)、Follower Replica(跟随者副本)、LEO(Log End Offset,日志结束偏移量)、HW(High Watermark,高水位)、Consumer Group(消费者组)等 。
 




推荐阅读