Skip to content

Commit

Permalink
Reduced ERROR level logging in KafkaAdminTopicConfigProvider
Browse files Browse the repository at this point in the history
Signed-off-by: Thomas Cooper <[email protected]>
  • Loading branch information
tomncooper committed Jun 3, 2021
1 parent 0e42039 commit f6319f5
Showing 1 changed file with 4 additions and 12 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -62,12 +62,8 @@ public Properties topicConfigs(String topic) {
.all()
.get()
.get(topicResource);
} catch (InterruptedException e) {
LOG.error("The request for the configuration of topic '{}' was interrupted", topic);
e.printStackTrace();
} catch (ExecutionException e) {
LOG.error("The request for the configuration of topic '{}' failed", topic);
e.printStackTrace();
} catch (InterruptedException | ExecutionException e) {
LOG.warn("Config check for topic {} failed due to failure to describe its configs.", topic, e);
}

if (topicConfig != null) {
Expand All @@ -93,12 +89,8 @@ public Map<String, Properties> allTopicConfigs() {
)
.get()
.get();
} catch (InterruptedException e) {
LOG.error("The request for the configuration of all topics was interrupted");
e.printStackTrace();
} catch (ExecutionException e) {
LOG.error("The request for the configuration of all topics failed");
e.printStackTrace();
} catch (InterruptedException | ExecutionException e) {
LOG.warn("Config check for all topics failed due to failure to describe their configs.", e);
}

Map<String, Properties> propsMap = new HashMap<>();
Expand Down

0 comments on commit f6319f5

Please sign in to comment.