franz-go
franz-go copied to clipboard
fix: Skip calculate lag when a topic has no offset commits
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.