skip topic when a TopicAuthorizationException occurs

obsidiandynamics · Jan 28, 2022 · e434dfa · e434dfa
1 parent e586fda
commit e434dfa
Showing 1 changed file with 1 addition and 14 deletions.
diff --git a/src/main/java/kafdrop/service/KafkaHighLevelAdminClient.java b/src/main/java/kafdrop/service/KafkaHighLevelAdminClient.java
@@ -109,7 +109,7 @@ Map<String, Config> describeTopicConfigs(Set<String> topicNames) {
       if (e.getCause() instanceof UnsupportedVersionException) {
         return Map.of();
       } else if (e.getCause() instanceof TopicAuthorizationException) {
-        printAcls();
+        return Map.of();
       }
       throw new KafkaAdminClientException(e);
     }
@@ -166,17 +166,4 @@ Collection<AclBinding> listAcls() {
     }
     return aclsBindings;
   }
-
-  private void printAcls() {
-    try {
-      final var acls = adminClient.describeAcls(new AclBindingFilter(ResourcePatternFilter.ANY, AccessControlEntryFilter.ANY)).values().get();
-      final var newlineDelimitedAcls = new StringBuilder();
-      for (var acl : acls) {
-        newlineDelimitedAcls.append('\n').append(acl);
-      }
-      LOG.info("ACLs: {}", newlineDelimitedAcls);
-    } catch (InterruptedException | ExecutionException e) {
-      LOG.error("Error describing ACLs", e);
-    }
-  }
 }