From caa5bb3da24dc9495b7656c2a7fd75adc5e872d3 Mon Sep 17 00:00:00 2001 From: Marcello Romani Date: Sun, 3 Mar 2024 14:28:38 +0000 Subject: [PATCH 1/2] log exception when unable to list topic names --- .../cruisecontrol/config/KafkaAdminTopicConfigProvider.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/config/KafkaAdminTopicConfigProvider.java b/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/config/KafkaAdminTopicConfigProvider.java index 44ffd0310e..080cdf4a10 100644 --- a/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/config/KafkaAdminTopicConfigProvider.java +++ b/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/config/KafkaAdminTopicConfigProvider.java @@ -140,7 +140,7 @@ public Map allTopicConfigs() { try { topicNames = _adminClient.listTopics().names().get(); } catch (InterruptedException | ExecutionException e) { - LOG.warn("Unable to obtain list of all topic names from the Kafka Cluster"); + LOG.warn("Unable to obtain list of all topic names from the Kafka Cluster: " + e); } if (topicNames == null) { From c073ddf9bb87278b67664156c888e89eb88f5451 Mon Sep 17 00:00:00 2001 From: Marcello Romani Date: Sun, 3 Mar 2024 14:29:02 +0000 Subject: [PATCH 2/2] log exception when unable to desribe kafka cluster configs --- .../cruisecontrol/config/KafkaAdminTopicConfigProvider.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/config/KafkaAdminTopicConfigProvider.java b/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/config/KafkaAdminTopicConfigProvider.java index 080cdf4a10..1d9e624e40 100644 --- a/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/config/KafkaAdminTopicConfigProvider.java +++ b/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/config/KafkaAdminTopicConfigProvider.java @@ -171,7 +171,7 @@ public void configure(Map configs) { try { clusterConfigs = describeClusterConfigs(_adminClient, DESCRIBE_CLUSTER_CONFIGS_TIMEOUT); } catch (InterruptedException | ExecutionException e) { - throw new RuntimeException("Failed to describe Kafka cluster configs."); + throw new RuntimeException("Failed to describe Kafka cluster configs: " + e); } if (clusterConfigs != null) {