Hi Viktor, We already have a method in Authorizer interface to get acls for a given principal. We will use this method to fetch acls and filter the results for requested Resources. Authorizer { def getAcls(principal: KafkaPrincipal): Map[Resource, Set[Acl]] } Currently AdminClient API doesn't have a API to fetch acls for a given principal. So while using AclCommand with AdminClient API (KIP-332), we just filter the results returned from describeAcls API. We can add new AdminClient API/new DescribeAclsRequest if required in future.
Updated the KIP. Thanks for the review. Thanks, On Wed, Aug 22, 2018 at 5:53 PM Viktor Somogyi-Vass <viktorsomo...@gmail.com> wrote: > Hi Manikumar, > > Implementation-wise is it just a filter over the returned ACL listing or do > you plan to add new methods to the Authorizer as well? > > Thanks, > Viktor > > On Fri, Aug 17, 2018 at 9:18 PM Priyank Shah <ps...@hortonworks.com> > wrote: > > > +1(non-binding) > > > > Thanks. > > Priyank > > > > On 8/16/18, 6:01 AM, "Manikumar" <manikumar.re...@gmail.com> wrote: > > > > Hi all, > > > > I have created a minor KIP to add support to list ACLs per principal > > using > > AclCommand (kafka-acls.sh) > > > > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-357%3A++Add+support+to+list+ACLs+per+principal > > > > Please take a look. > > > > Thanks, > > > > > > >