09｜消费端：消费者客户端的SDK有哪些设计要点？（下）

消费者客户端SDK设计总结 消费分组 通过消费者分组可以管理消费者消息的消费，一个集群中可以有很多消费组，消费者相关的元数据信息会保存在Broker的元数据存储服务中。 一个消费组可以订阅多个Topic，一个Topic也可以被多个消费组订阅和消费。 消费重平衡（Rebalance） 一般会为每个消费者分配对应的消息队列，这个分配的过程叫做消费重平衡（Rebalance），协调者的工作就是执行消费重平衡。以下两种方案： （1）协调者进行分配：协调者内部完成消费重平衡之后，将分配结果同步给所有消费者； （2）在消费者端完成：不需要协调者，每个消费者在自己本地进行消费重平衡，RocketMQ在5.0之前采用的就是这种方式； 一般消费者发生变化（上线或者下线）/ Topic分区/队列发生变化的时候，会触发执行消费重平衡。 分配策略 分区/消费队列的分配策略一般有以下几大类： （1）轮询，将分区/队列排序，按顺序依次分配给各个消费者，如果分区/队列数量与消费者数量不均衡，有可能出现某个消费者分配过多或者有些消费者没有队列可以分配的情况，导致负载倾斜； （2）粘性：尽量减少分区分配关系的变动，从而减少重平衡所耗费的时间和资源损耗； （3）自定义分配策略； RocketMQ在5.0以前按队列粒度分配给消费者，主要有以下几种策略： （1）平均分配策略； （2）平均轮询分配策略； （3）一致性hash分配； （4）根据配置进行分配； （5）根据机房分配； （6）优先分配同机房策略； Rocket5.0以后可以按照消息粒度，将消息直接分配到消费者消费，具体可以参考官方文档： https://rocketmq.apache.org/zh/docs/featureBehavior/08consumerloadbalance 消费确认 消息消费完毕之后，需要向服务端发送ACK，服务端一般有两种方式处理消费后的消息： （1）删除数据：每条消只能被消费一次，这种方案一般很少采用； （2）保存消费进度：服务端保存每个队列的消费进度（一般会按消费者划分），数据的删除交由过期策略执行，消息队列大多数采用的就是这种方案；

“通过消费分组的名称计算出来一个 hash 值和 __consumer_offset 的分区数，取余计算得出一个分区号”，请问下文强老师，这个计算的操作是由谁来完成的呢？