add delete acl entry from acl detail

This commit is contained in:
许晓东
2021-09-04 18:21:47 +08:00
parent 399d67fd3c
commit bb8db4f6f3
6 changed files with 49 additions and 5 deletions

View File

@@ -121,6 +121,10 @@ class KafkaAclConsole(config: KafkaConfig) extends KafkaConsole(config: KafkaCon
}).asInstanceOf[Boolean]
}
def deleteAcl(entry: AclEntry): Boolean = {
deleteAcl(Collections.singleton(entry.toAclBindingFilter))
}
def deleteUserAcl(entry: AclEntry): Boolean = {
val filter: AclBindingFilter = entry.toAclBindingFilter
val delFilter = new AclBindingFilter(new ResourcePatternFilter(ResourceType.ANY, null, filter.patternFilter().patternType()),