From f1af2e42838e2a1e3e372766833a32baa00d1782 Mon Sep 17 00:00:00 2001
From: David Faillefer <david.faillefer@unabiz.com>
Date: Mon, 6 Mar 2023 09:13:45 +0100
Subject: [PATCH]  #2443 Use version 4 of DescribeGroupsRequest only if kafka
 broker version is geater  than 2.4.0.0

---
 admin.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/admin.go b/admin.go
index a334daff55..f5d1427a04 100644
--- 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)