Merge pull request #1452 from symaras/1451

Set the Kafka version in ListAcls method
IBM · Aug 14, 2019 · 25c9059 · 25c9059
2 parents 43f1fb8 + 49309c8
commit 25c9059
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/admin.go b/admin.go
@@ -513,6 +513,10 @@ func (ca *clusterAdmin) ListAcls(filter AclFilter) ([]ResourceAcls, error) {
 
 	request := &DescribeAclsRequest{AclFilter: filter}
 
+	if ca.conf.Version.IsAtLeast(V2_0_0_0) {
+		request.Version = 1
+	}
+
 	b, err := ca.Controller()
 	if err != nil {
 		return nil, err