From 6cd87643c36ee013f37be701a18da0a3c53a6010 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=AE=B8=E6=99=93=E4=B8=9C?= <763795151@qq.com> Date: Wed, 8 Sep 2021 11:41:31 +0800 Subject: [PATCH] fix acl detail do not show the acl list if the host is not wildcard --- src/main/scala/kafka/console/KafkaAclConsole.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/scala/kafka/console/KafkaAclConsole.scala b/src/main/scala/kafka/console/KafkaAclConsole.scala index cd17676..ef85d3a 100644 --- a/src/main/scala/kafka/console/KafkaAclConsole.scala +++ b/src/main/scala/kafka/console/KafkaAclConsole.scala @@ -44,8 +44,10 @@ class KafkaAclConsole(config: KafkaConfig) extends KafkaConsole(config: KafkaCon if (StringUtils.isNotBlank(entry.getPrincipal()) && !KafkaPrincipal.ANONYMOUS.toString.equalsIgnoreCase(f.entryFilter().principal())) { principal = f.entryFilter().principal(); } + + val host: String = if (entry.getHost != null) f.entryFilter().host() else null val filter = new AclBindingFilter(new ResourcePatternFilter(resourceType, name, f.patternFilter().patternType()), - new AccessControlEntryFilter(principal, f.entryFilter().host(), AclOperation.ANY, AclPermissionType.ANY)) + new AccessControlEntryFilter(principal, host, AclOperation.ANY, AclPermissionType.ANY)) log.info(filter.toString) withAdminClient(adminClient => adminClient.describeAcls(filter).values().get()).asInstanceOf[List[AclBinding]] }