Kafka消费者之Group Coordinator原理

消费者是如何实现rebalance的? 1. 什么是coordinator? 每个consumer group 都会选择一个broker作为自己的coordinator,他是负责监控整个消费组里的各个分区的心跳,以及判断是否宕机,和开启rebalance的。 2. 如何选择coordinator机器 首先对group id 进行hash,接着对__consumer_offsets的分区数量进行取模
相关文章
相关标签/搜索