Skip to content

Commit

Permalink
Merge pull request #1458 from agapoff/admin-createacl-request-version
Browse files Browse the repository at this point in the history
Set request version in CreateACL ClusterAdmin method
  • Loading branch information
bai authored Aug 16, 2019
2 parents 25c9059 + 59711ce commit 88444de
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions admin.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 88444de

Please sign in to comment.