揭秘kafka消费者二(提交和偏移量)

提交和偏移量 本文介绍kafka消费者非常重要的内容-提交和偏移量,介绍前,我们先弄清楚两个基本概念和面临的问题: 一:基本概念 提交:把更新分区当前位置的操作叫做提交。 消费者偏移量:保存已经处理的每个分区的偏移量。 二:面临的问题 消息被重复处理:提交的偏移量小于客户端处理的最后一个消息的偏移量,那么处于两个偏移量之间的消息就会被重复处理。 消息丢失:如果提交的偏移量大于客户端处理的最后一个消
相关文章
相关标签/搜索