kafkakafka 数据重复的一个 案例

Posted 2021-09-13 九师兄

文章目录

• 1.概述

1.概述

有人问我

假如有一个tp叫做小乌龟，12个分区，单个进程请求，一次poll60条记录，10ms消费完了，设置了自动提交，时间是5s。那我下次poll的时候一定会重复吧？刚才做了这个实验，发现并没有重复，有点疑惑。

然后我就测试了一下

/**
     * 测试点：假如有一个tp叫做小乌龟，12个分区，单个进程请求，一次poll60条记录，10ms消费完了，设置了自动提交，
     *   时间是5s。那我下次poll的时候一定会重复吧？刚才做了这个实验 发现并没有重复，有点疑惑。
     *
     * 测试结果：
     *  我第一次启动，消费5个数据后，立马关闭程序，还没到10秒提交消费组的时候
     *  然后第二次启动消费组就重新消费了
     *
     * @throws InterruptedException