fix(kafka consumer-group): use group id filter for dynamic completions (#827)

rkpattnaik780 · web-flow · commit 6511f148b268 · 2021-07-21T22:29:21.000+05:30
diff --git a/pkg/cmdutil/cmdutil.go b/pkg/cmdutil/cmdutil.go
@@ -90,6 +90,9 @@ func FilterValidConsumerGroupIDs(f *factory.Factory, toComplete string) (validID
 		return validIDs, directive
 	}
 	req := api.GetConsumerGroups(context.Background())
+	if toComplete != "" {
+		req = req.GroupIdFilter(toComplete)
+	}
 
 	cgRes, _, err := req.Execute()
 	if err != nil {

Original file line number	Diff line number	Diff line change
`@@ -90,6 +90,9 @@ func FilterValidConsumerGroupIDs(f *factory.Factory, toComplete string) (validID`
`90`	`90`	`return validIDs, directive`
`91`	`91`	`}`
`92`	`92`	`req := api.GetConsumerGroups(context.Background())`
	`93`	`+ if toComplete != "" {`
	`94`	`+ req = req.GroupIdFilter(toComplete)`
	`95`	`+ }`
`93`	`96`
`94`	`97`	`cgRes, _, err := req.Execute()`
`95`	`98`	`if err != nil {`