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 <[email protected]>
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 <[email protected]>
> wrote:
>
> > +1(non-binding)
> >
> > Thanks.
> > Priyank
> >
> > On 8/16/18, 6:01 AM, "Manikumar" <[email protected]> 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,
> >
> >
> >
>
