Skip to content

Commit 9569753

Browse files
authored
Merge pull request #584 from twmb/kadm_lag_patch
kadm: populate GroupMemberLag.{Topic,Partition} always
2 parents 4449480 + 1c2ccf9 commit 9569753

File tree

1 file changed

+7
-5
lines changed

1 file changed

+7
-5
lines changed

pkg/kadm/groups.go

+7-5
Original file line numberDiff line numberDiff line change
@@ -1618,9 +1618,9 @@ func calculateEmptyLag(commit OffsetResponses, endOffsets ListedOffsets) GroupLa
16181618
}
16191619

16201620
lt[p] = GroupMemberLag{
1621-
Commit: pcommit.Offset,
16221621
Topic: t,
16231622
Partition: p,
1623+
Commit: pcommit.Offset,
16241624
End: pend,
16251625
Lag: lag,
16261626
Err: perr,
@@ -1650,10 +1650,12 @@ func calculateEmptyLag(commit OffsetResponses, endOffsets ListedOffsets) GroupLa
16501650
lag = pend.Offset
16511651
}
16521652
lt[p] = GroupMemberLag{
1653-
Commit: pcommit,
1654-
End: pend,
1655-
Lag: lag,
1656-
Err: perr,
1653+
Topic: t,
1654+
Partition: p,
1655+
Commit: pcommit,
1656+
End: pend,
1657+
Lag: lag,
1658+
Err: perr,
16571659
}
16581660
}
16591661
}

0 commit comments

Comments
 (0)