New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

增加对pending状态数据的处理 #6

Closed

chaz6chez opened this issue Aug 8, 2023 · 0 comments

Labels

Member

chaz6chez commented Aug 8, 2023

现状

极端情况下可能存在数据消费成功但未ack
未ack数据虽然不会被当前消费组消费但存在数据冗余

目标

将pending数据ack

方案

在消费者主定时器中增加xClaim逻辑，读取config中的消息最大等待时间
单独启动一个独立定时器，使用与消费者相同的消费组进行xClaim处理，读取config中的消息最大等待时间

chaz6chez added the enhancement label

chaz6chez added a commit that referenced this issue


          close #6

d7fe5c5

close #7

chaz6chez closed this as completed

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment