kafka对消费者分配分区规则（Java源码)

在上一篇 kafka topic消息分配partition规则（Java源码) 咱们对生产者产生的消息分配partition规则进行了分析，那么本章咱们来看看消费者是怎么样分配partition的。html 　　kafka 为了保证同一类型的消息顺序性（FIFO），一个partition只能被同一组的一个consumer绑定消费，不一样组的consumer能够绑定同一个partition进行重复消

>>阅读原文<<