|
|
@@ -500,6 +500,10 @@ func (ca *clusterAdmin) CreateACL(resource Resource, acl Acl) error {
|
|
|
acls = append(acls, &AclCreation{resource, acl})
|
|
|
request := &CreateAclsRequest{AclCreations: acls}
|
|
|
|
|
|
+ if ca.conf.Version.IsAtLeast(V2_0_0_0) {
|
|
|
+ request.Version = 1
|
|
|
+ }
|
|
|
+
|
|
|
b, err := ca.Controller()
|
|
|
if err != nil {
|
|
|
return err
|