Skip to content

Commit

Permalink
skip topic when a TopicAuthorizationException occurs
Browse files Browse the repository at this point in the history
  • Loading branch information
Jork Zijlstra authored and davideicardi committed Jan 31, 2022
1 parent d9243d8 commit 60d9db2
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -110,6 +110,7 @@ Map<String, Config> describeTopicConfigs(Set<String> topicNames) {
return Map.of();
} else if (e.getCause() instanceof TopicAuthorizationException) {
printAcls();
return Map.of();
}
throw new KafkaAdminClientException(e);
}
Expand Down

0 comments on commit 60d9db2

Please sign in to comment.