add missing group metadata to commit offsets call

twmb · Jan 23, 2025 · 049514f · 049514f
1 parent f30c518
commit 049514f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/kadm/groups.go b/pkg/kadm/groups.go
@@ -755,6 +755,7 @@ func (os OffsetResponses) Ok() bool {
 func (cl *Client) CommitOffsets(ctx context.Context, group string, os Offsets) (OffsetResponses, error) {
 	req := kmsg.NewPtrOffsetCommitRequest()
 	req.Group = group
+	req.MemberID, req.Generation = cl.cl.GroupMetadata()
 	for t, ps := range os {
 		rt := kmsg.NewOffsetCommitRequestTopic()
 		rt.Topic = t