看一下分配策略:
1 消费者组会向kafka发起一个选择组长的请求
2 kafka服务器会进行选择,先选出服务器中的一台作为组长,一般是leader的那台会选择为组长
3 kafka组长会选出一个消费者组长,选择的策略是根据谁的性能好选择谁为组长
4 kafka-组长会给消费者组制定一个消费策略,即消费者和分区之间的对应消费关系
这个消费策略有三种分配的方式,
4.1 range
4.2 round-robin
4.3 sticky
5 kafka会将这个消费策略分发给各消费者,会在心跳的时候发送这个方案