kgo handleListGroups: copy Version and ThrottleMillis in merging

twmb · Aug 24, 2020 · 4eb5940 · 4eb5940
1 parent ff1dc46
commit 4eb5940
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/kgo/client.go b/pkg/kgo/client.go
@@ -1011,6 +1011,8 @@ func (cl *Client) handleListGroupsReq(ctx context.Context, req *kmsg.ListGroupsR
 		if mergeResp.ErrorCode == 0 {
 			mergeResp.ErrorCode = resp.ErrorCode
 		}
+		mergeResp.Version = resp.Version
+		mergeResp.ThrottleMillis = resp.ThrottleMillis
 		mergeResp.Groups = append(mergeResp.Groups, resp.Groups...)
 	}