From 1c2ccf9d805da7e3ef0831755c966dd42ac9896c Mon Sep 17 00:00:00 2001 From: Travis Bischel Date: Fri, 29 Sep 2023 11:19:38 -0600 Subject: [PATCH] kadm: populate GroupMemberLag.{Topic,Partition} always This was missing in one spot. --- pkg/kadm/groups.go | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/pkg/kadm/groups.go b/pkg/kadm/groups.go index 1509fb4a..0b2601b1 100644 --- a/pkg/kadm/groups.go +++ b/pkg/kadm/groups.go @@ -1618,9 +1618,9 @@ func calculateEmptyLag(commit OffsetResponses, endOffsets ListedOffsets) GroupLa } lt[p] = GroupMemberLag{ - Commit: pcommit.Offset, Topic: t, Partition: p, + Commit: pcommit.Offset, End: pend, Lag: lag, Err: perr, @@ -1650,10 +1650,12 @@ func calculateEmptyLag(commit OffsetResponses, endOffsets ListedOffsets) GroupLa lag = pend.Offset } lt[p] = GroupMemberLag{ - Commit: pcommit, - End: pend, - Lag: lag, - Err: perr, + Topic: t, + Partition: p, + Commit: pcommit, + End: pend, + Lag: lag, + Err: perr, } } }