kafka之协调者

一、消费者加入消费组 1、加入组请求的业务逻辑主要步骤如下：    （1）、消费者加入消费组之前，需要做一些准备工作，比如同步提交一次偏移量，执行监听器的回调。    （2）、消费者创建“加入组请求”，包括消费者的元数据作为请求的数据内容。    （3）、消费者发送“加入组请求”，采用组合模式返回一个新的异步请求对象，并定义回调处理器。    （4）、客户端通过轮询，确保组合模式返回的异步请求必须

>>阅读原文<<