From 23d4561d064a1d0cc89b058deb50efbeecde58c5 Mon Sep 17 00:00:00 2001
From: Dominic Evans <dominic.evans@uk.ibm.com>
Date: Thu, 3 Aug 2023 14:41:51 +0100
Subject: [PATCH] chore(proto): permit DeleteGroupsRequest V1

This is identical in format to V0, but just influences the broker's response behaviour

Signed-off-by: Dominic Evans <dominic.evans@uk.ibm.com>
---
 admin.go                  |  3 +++
 delete_groups_request.go  | 11 +++++++++--
 delete_groups_response.go | 11 +++++++++--
 3 files changed, 21 insertions(+), 4 deletions(-)

diff --git a/admin.go b/admin.go
index d226b7623..a6114a867 100644
--- a/admin.go
+++ b/admin.go
@@ -1033,6 +1033,9 @@ func (ca *clusterAdmin) DeleteConsumerGroup(group string) error {
 	request := &DeleteGroupsRequest{
 		Groups: []string{group},
 	}
+	if ca.conf.Version.IsAtLeast(V2_0_0_0) {
+		request.Version = 1
+	}
 
 	resp, err := coordinator.DeleteGroups(request)
 	if err != nil {
diff --git a/delete_groups_request.go b/delete_groups_request.go
index 2158370d5..2fdfc3386 100644
--- a/delete_groups_request.go
+++ b/delete_groups_request.go
@@ -27,11 +27,18 @@ func (r *DeleteGroupsRequest) headerVersion() int16 {
 }
 
 func (r *DeleteGroupsRequest) isValidVersion() bool {
-	return r.Version == 0
+	return r.Version >= 0 && r.Version <= 1
 }
 
 func (r *DeleteGroupsRequest) requiredVersion() KafkaVersion {
-	return V1_1_0_0
+	switch r.Version {
+	case 1:
+		return V2_0_0_0
+	case 0:
+		return V1_1_0_0
+	default:
+		return V2_0_0_0
+	}
 }
 
 func (r *DeleteGroupsRequest) AddGroup(group string) {
diff --git a/delete_groups_response.go b/delete_groups_response.go
index 2d77ed2b2..e490f8314 100644
--- a/delete_groups_response.go
+++ b/delete_groups_response.go
@@ -71,11 +71,18 @@ func (r *DeleteGroupsResponse) headerVersion() int16 {
 }
 
 func (r *DeleteGroupsResponse) isValidVersion() bool {
-	return r.Version == 0
+	return r.Version >= 0 && r.Version <= 1
 }
 
 func (r *DeleteGroupsResponse) requiredVersion() KafkaVersion {
-	return V1_1_0_0
+	switch r.Version {
+	case 1:
+		return V2_0_0_0
+	case 0:
+		return V1_1_0_0
+	default:
+		return V2_0_0_0
+	}
 }
 
 func (r *DeleteGroupsResponse) throttleTime() time.Duration {