jd-opensource / jd-opensource/joyqueue

archive issue: consume log exception

未关闭
#322 3 条评论 0 个 reaction 已指派 1 人 已指派给 @minusmajun 在 GitHub 查看
主要语言
Java
星标
383
派生
139
PR 合并指标
30 天内没有已合并 PR

描述

归档功能异常:消费归档功能里,在批量进行读取消费记录日志文件的时候,如果读取是在两个文件里进行的(比如批量1000条,500条读取完后再进行下一个文件的500条读取),操作hbase存储如果出现异常的话进行位置回退处理,此时的回退处理是对1000条整体位置的偏移量进行回退,但偏移量横跨两个文件进行读取计算的,所以会导致回退偏移量设置异常,从而影响整个消费记录日志的存储线程。

贡献指南

打开贡献指南

评估

这个 Issue 还没有评估数据。

把新 issue 发到你的邮箱

精选适合新手参与的 GitHub issue 摘要。