分布式消息服务KAFKA版-消息从生产到消费时延高达6分钟:背景知识介绍

时间:2024-11-11 15:36:41

背景知识介绍

消费组可以简单认为有两种状态REBALANCING和STABILIZED。

  • REBALANCING:消费组元数据发生变化,该状态下消费组中的所有消费者都无法进行正常的业务消费,该场景触发场景为消费组内有新的消费者加入或有已经建立连接的消费者退出。
  • STABILIZED:rebalance完成,消费组处于稳定状态,该状态下消费组中的消费者可以进行正常的业务消费,触发条件是,当前消费组内的所有消费者都同步完成新的消费组元数据,包括之前已经同步过的消费者,也需要重新同步。

消费组简单流程如下:

  1. 有新的消费者加入或退出,服务端记录的消费组元数据更新,服务端更新消费组进入REBALANCING状态。
  2. 服务端等待所有消费者(包含已有的消费者)同步最新的元数据。
  3. 所有消费者同步完最新的元数据后,服务端更新消费组状态为STABILIZED。
  4. 消费者开始正常的消费业务。
support.huaweicloud.com/trouble-kafka/kafka-trouble-0709001.html