kafkakafka 消费组 加入 离开 reblance 案例

Posted 2021-09-13 九师兄

文章目录

• 1.概述

1.概述

本故事起源于一个朋友问的问题，如下

如果12个分区，12个消费者，都是自动提交5s，且处理得6秒，以此以1秒间隔启动他们，这样最终会导致，每次poll，每个消费者都得被再平衡一次吧。

我做了如下的案例

public class MultipleConsumerReblance {
   

    /**
     * 测地点：如果12个分区，12个消费者，都是自动提交5s，且处理得6秒，以此以1秒间隔启动他们，这样最终会导致，每次poll，
     * 每个消费者都得被再平衡一次吧。
     */