Parcourir la source

Set request version in CreateACL ClusterAdmin method

Vitaly Agapov il y a 6 ans
Parent
commit
59711ced3d
1 fichiers modifiés avec 4 ajouts et 0 suppressions
  1. 4 0
      admin.go

+ 4 - 0
admin.go

@@ -500,6 +500,10 @@ func (ca *clusterAdmin) CreateACL(resource Resource, acl Acl) error {
 	acls = append(acls, &AclCreation{resource, acl})
 	acls = append(acls, &AclCreation{resource, acl})
 	request := &CreateAclsRequest{AclCreations: acls}
 	request := &CreateAclsRequest{AclCreations: acls}
 
 
+	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 err
 		return err