IBM#2443 Use version 4 of DescribeGroupsRequest only if kafka broker…

… version is geater than 2.4.0.0
faillefer · Mar 6, 2023 · f1af2e4 · f1af2e4
1 parent 397cee4
commit f1af2e4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/admin.go b/admin.go
@@ -891,7 +891,7 @@ func (ca *clusterAdmin) DescribeConsumerGroups(groups []string) (result []*Group
 		describeReq := &DescribeGroupsRequest{
 			Groups: brokerGroups,
 		}
-		if ca.conf.Version.IsAtLeast(V2_3_0_0) {
+		if ca.conf.Version.IsAtLeast(V2_4_0_0) {
 			describeReq.Version = 4
 		}
 		response, err := broker.DescribeGroups(describeReq)