Kafka consumer 端设计 cousumer group 状态机

consumer依赖broker端的组协调者coordinator来管理组内所有的sonsumer实例 并负责把分配方案下发到每个consumer上，分配方案是由组内的leader sonsumer来根据指定的分配策略来决定的。该分配策略必须是组内所有consumer都支持的。如果所有sonsumer在一起无法选择共同的策略 那么将抛出异常。这种设计确保了consumer group的一致性。同时

>>阅读原文<<