From be0cd503dacd76246b407a7808981a16f93e4590 Mon Sep 17 00:00:00 2001 From: Gergely Harmadas Date: Tue, 12 Nov 2024 15:50:52 +0100 Subject: [PATCH] expose AdminClient exception when failing to describe the cluster --- .../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..ef86d5334a 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) {