add ctx to optvalues

twmb · Feb 18, 2025 · 66f9c95 · 66f9c95
1 parent 8b120ca
commit 66f9c95
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/kgo/client.go b/pkg/kgo/client.go
@@ -398,6 +398,8 @@ func (cl *Client) OptValues(opt any) []any {
 		return []any{cfg.requireStable}
 	case namefn(SessionTimeout):
 		return []any{cfg.sessionTimeout}
+	case namefn(WithContext):
+		return []any{cfg.ctx}
 	default:
 		return nil
 	}