Browse Source

Set request version in DeleteACL ClusterAdmin method

Vitaly Agapov 6 years ago
parent
commit
0d98f3a519
1 changed files with 4 additions and 0 deletions
  1. 4 0
      admin.go

+ 4 - 0
admin.go

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