【kafka】kafka 数据重复的一个 案例 ﹏ヽ暗。殇╰゛Y 2022-09-09 02:10 300阅读 0赞 ### 文章目录 ### * 1.概述 ![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Lmd5biI5YWE_size_20_color_FFFFFF_t_70_g_se_x_16] # 1.概述 # 有人问我 假如有一个tp叫做小乌龟，12个分区，单个进程请求，一次poll60条记录，10ms消费完了，设置了自动提交，时间是5s。那我下次poll的时候一定会重复吧？刚才做了这个实验，发现并没有重复，有点疑惑。 然后我就测试了一下 /** * 测试点：假如有一个tp叫做小乌龟，12个分区，单个进程请求，一次poll60条记录，10ms消费完了，设置了自动提交， * 时间是5s。那我下次poll的时候一定会重复吧？刚才做了这个实验 发现并没有重复，有点疑惑。 * * 测试结果： * 我第一次启动，消费5个数据后，立马关闭程序，还没到10秒提交消费组的时候 * 然后第二次启动消费组就重新消费了 * * @throws InterruptedException [watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Lmd5biI5YWE_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220829/7cda395d99d54e9783e0d5b6e8e7c91a.png
还没有评论，来说两句吧...