franz-go icon indicating copy to clipboard operation
franz-go copied to clipboard

fix: Skip calculate lag when a topic has no offset commits

Open kylege opened this issue 1 month ago • 3 comments

If topic has no commit offset for a consumer group, then we should not calculate lag for it.

For example, topic A current high water offset is 100, but has no message because of delete mode

And there will not be any offset commits for consumer group because there is no messages to consume

Function CalculateGroupLag will calculate lag 100 for the consumer group, which is wrong.

kylege avatar May 08 '24 08:05 kylege