Browse Source

Set the Kafka version in ListAcls method

Symeon Meichanetzoglou 6 năm trước cách đây
mục cha
commit
8c12b175c4
1 tập tin đã thay đổi với 4 bổ sung0 xóa
  1. 4 0
      admin.go

+ 4 - 0
admin.go

@@ -508,6 +508,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