'Delete the READ access on that topic with the principal using java code

public void deleteReadAcl(AdminClient adminClient, TopicReadRequest deleteAclRequest) {

    ResourcePatternFilter resourcePatternFilter = new ResourcePatternFilter(ResourceType.GROUP, deleteAclRequest.getConsumerGroup(), PatternType.ANY);
    AccessControlEntryFilter accessControlEntryFilter = new AccessControlEntryFilter(deleteAclRequest.getPrincipal(), null, AclOperation.READ,AclPermissionType.ALLOW);
    AclBindingFilter aclBindingFilter = new AclBindingFilter(resourcePatternFilter, accessControlEntryFilter);
    Set<AclBindingFilter> bindingFilters = new HashSet<>();
    bindingFilters.add(aclBindingFilter);
    System.out.println("acl to be delted === "+bindingFilters);

    adminClient.deleteAcls(bindingFilters);
javaapache-kafkaprincipal


Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution Source

Related Questions