5.3.5 消费组未稳定，原有消费者重新加入消费组

r囧r小猫 2023-01-13 15:58 101阅读 0赞

#### 5.3.5 消费组未稳定，原有消费者重新加入消费组 ####

> 再来看另一种场景：其他消费者发送“加入组请求”先于第一个消费者发送“同步组请求”。协调者返回“加入组响应”给第一个消费者，并更改消费组状态为“等待同步”。第一个消费者收到“加入组响应”后，但还没完成分区分配的工作，就有新的消费者发送了“加入组请求”。这时候其实第一个消费者是不需要执行分区分配的，因为即使执行了，也只有它一个的，并不会包含新加入的第二个消费者。

如图5-10（上)所示，第一个消费者完成分区分配工作后，“同步组请求”的消费组分配结果只有第一个消费者的数据。此时，第一个消费者将分配结果发送给协调者，协调者是不会接受的。因为协调者已经处理了第二个消费者的“加入组请求”，消费组的状态被更改为“准备再平衡”。第二个消费者在这个状态下，会收到REBALANCE\_IN\_PROGRESS的错误码，井重新发送“加入组请求”。

如图5-10（下)所示，第一个消费者重新发送了“加入组请求”，协调者对第一个消费者重新发送的“加入组请求”，也会尝试完成第二个消费者创建的延迟操作。因为满足可以完成延迟操作的条件，所以协调者会再次将消费组状态改为“等待同步”，并返回“加入组响应”给两个消费者。后续协调者处理两个消费者的“同步组请求”，第二个消费者不是主消费者，只会设置消费者成员元数据中的回调方法。当第一个消费者执行完分区分配后，协调者处理第一个消费者的“同步组请求”，会同时返回“同步组响应”给两个消费者。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1dBTlRBV0FZMzE0_size_16_color_FFFFFF_t_70]

在5.3.4节中，消费组状态为“稳定”后，当有新消费者加入消费组，并将消费组状态更改为“准备再平衡”，原有的消费者是通过心跳的方式感知到要重新发送“加入组请求”。而这里，消费组状态还是“等待同步”，就有新消费者加入消费组，也更改消费组状态为“再平衡”。由于消费组状态未稳定，原有的消费者不会有心跳任务，所以协调者采用返回错误码的方式通知原有的消费者。即消费者在发送“同步组请求”时，如果消费组状态为“准备再平衡”，协调者会要求消费者重新发送“加入组请求”。相关代码如下：  
![在这里插入图片描述][20210412220142677.png]

消费者发送“加入组请求”如果收到有错误码的结果，会主动重新发送“加入组请求”给协调者。消费者在请求发送前调用一次onJoinPrepare（)，在请求成功完成调用一次onJoinComplete（)方法。这两个方法在消费者的一次再平衡操作中，即使发送了多次“加入组请求”，也都只会被调用一次。相关代码如下：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1dBTlRBV0FZMzE0_size_16_color_FFFFFF_t_70 1]

这一节主要分析了协调者在处理消费者的“加入组请求”时，使用一个“延迟操作”对象表示延迟返回“加入组响应”给消费者。延迟操作创建时，伴随着消费组状态从“稳定”转变为“准备再平衡”；延迟操作完成时，消费组状态会从“准备再平衡”转变为“等待同步”。另外，我们还分析了协调者处理不同消费者的“加入组请求”和“同步组请求”的两种案例，下面我们来分析消费组处理这两种请求的状态机实现。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1dBTlRBV0FZMzE0_size_16_color_FFFFFF_t_70]: /images/20221022/bb97aaaaa03d488db3e1da7cbcf14996.png
[20210412220142677.png]: /images/20221022/224b331fb5b94fda829f19c944cbb5e8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1dBTlRBV0FZMzE0_size_16_color_FFFFFF_t_70 1]: /images/20221022/6b1886247f27474abd1820bae1543abf.png