5.3.4 消费组稳定后，原有消费者重新加入消费组

冷不防 2023-01-13 15:58 126阅读 0赞

#### 5.3.4 消费组稳定后，原有消费者重新加入消费组 ####

> 协调者在处理消费者发送的“加入组请求”和“同步组请求”时，都会依赖于消费组当前的状态进入不同的分支流程。假设第一个消费者完成一次再平衡操作后，又有新的消费者发送了“加入组请求”。如图5-9所示，新消费者会发起新的再平衡操作，原有的消费者也需要重新发送“加入组请求”，具体步骤如下。

(1)（图5-9（左))第一个消费者发送“加入组请求”，也完成了延迟操作，会将它的回调方法重置为空。
    (2)（图5-9（中))协调者处理第二个消费者的“加入组请求”，消费组状态已经是“稳定”。和处理第一个消费者的“加入组请求”类似，它也会将消费组状态改为“准备再平衡”，井创建一个延迟的操作对象。
    (3)（图5-9（中))协调者创建完延迟操作后，通过延迟缓存尝试完成刚刚创建的延迟操作。但和协调者处理第一个消费者不一样，这时尝试完成的条件不能满足，处理第二个消费者的“加入组请求”就结束了。
    (4)虽然协调者处理第二个消费者的“加入组请求”结束了，但延迟操作对象还不能完成，延迟操作对象会被加入到延迟缓存的监控列表中。后续要完成延迟操作，有两种办法：外部事件触发、超时触发。
    (5)（图5-9（右))协调者等待第一个消费者重新发送“加入组请求”。如果第一个消费者在超时时间内重新发送“加入组”请求，再次调用“尝试完成延迟操作”（外部事件触发)，满足完成延迟操作的条件。延迟操作会从延迟缓存中移除，并调用延迟操作完成的回调方法，返回“加入组响应”给所有的两个消费者。
    (6)但如果第一个消费者在会话超时时间内没有重新发送“加入组请求二，消费组成员元数据中第一个消费者的回调方法一直是空的。协调者会在迟操作超时后，强制完成超时的延迟操作。这时也会调用延迟操作完成的回调方法，但只返回“加入组响应”给第二个消费者（因为第一个消费者的回调方法为空，所以并不会返回响应结果给第一个消费者)。

协调者在处理第一个消费者的“加入组请求”时，创建的延迟操作对象会立即完成。但处理第二个消费者的“加入组请求”时，消费组中已经存在第一个消费者的成员元数据，此时消费组中总共有两个消费者了。但是第一个消费者成员元数据的回调方法在协调者返回“加入组响应”给它时，就被重置为空了。协调者在处理第二个消费者的“加入组请求”时，第二个消费者成员元数据的回调方法不为空。

消费组元数据的notYetRejoi.nedMel’lbers（)方法，表示还没重新发送“加入组请求”的消费者成员。如果该方法的返回值有数据，说明还有消费者成员没发送“加入组请求”。这里的消费者成员必须是存在于消费组中的消费者成员，也是之前发送过“加入组请求”的成员，所以才表示“重新发送”。

注意：对于第一次加入消费组的消费者成员而言，它们之前就不在消费组中，就不算作“重新发送飞当消费者发送过一次“加入组请求”后，就会被保存在消费组的元数据中。如果再次发生再平衡操作，已存在消费组中的所有消费者都要重新发送“加入组请求”。notYetRejoinedMefllbers（)方法用来判断延迟的操作对象能否完成。如果存在于消费组中的消费者没有重新发送“加入纽请求”，延迟操作就不能完成。而如果存在于消费组中的所有消费者都重新发送了“加入组请求”，延迟操作就可以认为完成，并且不需要等到再平衡设直的超时时间到达，就可以提前完成延迟操作。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1dBTlRBV0FZMzE0_size_16_color_FFFFFF_t_70]

--------------------

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1dBTlRBV0FZMzE0_size_16_color_FFFFFF_t_70]: /images/20221022/d0a119f4214242a69a446ad7475f15ae.png