From 0d98f3a51963830744735d9817a776a7473b5066 Mon Sep 17 00:00:00 2001
From: Vitaly Agapov <v.agapov@quotix.com>
Date: Mon, 19 Aug 2019 11:19:46 +0300
Subject: [PATCH] Set request version in DeleteACL ClusterAdmin method

---
 admin.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/admin.go b/admin.go
index ac3810ca1..0e3304661 100644
--- a/admin.go
+++ b/admin.go
@@ -535,6 +535,10 @@ func (ca *clusterAdmin) DeleteACL(filter AclFilter, validateOnly bool) ([]Matchi
 	filters = append(filters, &filter)
 	request := &DeleteAclsRequest{Filters: filters}
 
+	if ca.conf.Version.IsAtLeast(V2_0_0_0) {
+		request.Version = 1
+	}
+
 	b, err := ca.Controller()
 	if err != nil {
 		return nil, err