产品分类

顾名思义，协调器负责协调工作。本节所讲的协调器，是用来协调消费者工作分配的。简单点说，就是消费者启动后，到可以正常消费前，这个阶段的初始化工作。消费者能够正常运转起来，全有赖于协调器。 主要的协调器有如下两个： 1、消费者协调器（ConsumerCoordinator） 2、组协调器（GroupCoordinator） 此外还有任务管理协调器（WorkCoordinator），用作kafka connect的works管理，本教程不做讲解。 kafka引入协调器有其历史过程，原来consumer信息依赖于zookeeper存储，当代理或消费者发生变化时，引发消费者平衡，此时消费者之间是互不透明的，每个消费者和zookeeper单独通信，容易造成羊群效应和脑裂问题。