Skip to content

Commit

Permalink
kadm: populate GroupMemberLag.{Topic,Partition} always
Browse files Browse the repository at this point in the history
This was missing in one spot.
  • Loading branch information
twmb committed Sep 29, 2023
1 parent 4449480 commit 1c2ccf9
Showing 1 changed file with 7 additions and 5 deletions.
12 changes: 7 additions & 5 deletions pkg/kadm/groups.go
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down Expand Up @@ -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,
}
}
}
Expand Down

0 comments on commit 1c2ccf9

Please sign in to comment.