KafkaAdminClient怎么实现消费者权限动态删除之后再赋予？

我调用KafkaAdminClient动态删除消费者的读权限的时候，消费者直接申请了离开小组的请求，然后再赋予权限消费者还是无法消费消息，必须重启消费者所在微服务才行。

下面是删除权限部分代码

 /**
     * 删除权限
     * @param resourceType topic类型还是group类型
     * @param name topic名或者group名
     * @param principal 用户名
     * @param aclOperation 读写权限
     */
    protected void deleteAcl(ResourceType resourceType, String name, String principal, AclOperation aclOperation) {
        ResourcePatternFilter  resourcePatternFilter = new ResourcePatternFilter(resourceType, name, PatternType.LITERAL);

        AccessControlEntryFilter  accessControlEntryFilter=new AccessControlEntryFilter ("User:" + principal, "*", aclOperation, AclPermissionType.ALLOW);

        AclBindingFilter aclBinding=new AclBindingFilter(resourcePatternFilter,accessControlEntryFilter);
        Collection<AclBindingFilter> aclBindingCollection= new ArrayList<>();
        aclBindingCollection.add(aclBinding);

        DeleteAclsResult aclResult = adminClient.deleteAcls(aclBindingCollection);
        KafkaFuture<Collection<AclBinding>> result = aclResult.all();
        try {
            result.get();
            if (result.isDone()){
                System.out.println(result.toString());
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

下面是消费者代码

@KafkaListener(topics = "${kafka.topic.name}", groupId = "#{'${kafka.consumer.group.id}'.split(',')[0]}")
    public void recieveData(ConsumerRecord consumerRecord) {
        log.info("Data - " + consumerRecord.value().toString() + " recieved");
        try {
            log.info("Group1 - 模拟业务开始");
            Thread.sleep(1000);
            log.info("Group1 - 模拟业务结束");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

错误日志截图，我也不懂哪些错误信息比较有用，我目前认为应该是消费者被删除权限之后，由于没有权限主动申请离开了消费组，再次赋予权限的时候他并没有发送重新加入小组的请求也就无法继续消费消息。能不能告诉我是我调用KafkaAdminClient写错了还是消费者部分写错了。最好能给出相应的解决方案。