fix(topicdata): handle unsupported DescribeLogDirs for MSK Serverless (…

…#1113) close #1112
tchiotludo · Jun 6, 2022 · 09ca266 · 09ca266
1 parent dbef78e
commit 09ca266
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/org/akhq/modules/AbstractKafkaWrapper.java b/src/main/java/org/akhq/modules/AbstractKafkaWrapper.java
@@ -16,6 +16,7 @@
 import org.apache.kafka.common.errors.ClusterAuthorizationException;
 import org.apache.kafka.common.errors.SecurityDisabledException;
 import org.apache.kafka.common.errors.TopicAuthorizationException;
+import org.apache.kafka.common.errors.UnsupportedVersionException;
 
 import java.util.*;
 import java.util.concurrent.ExecutionException;
@@ -254,7 +255,7 @@ public Map<Integer, Map<String, LogDirDescription>> describeLogDir(String cluste
                             .allDescriptions()
                             .get();
                     } catch (ExecutionException e) {
-                        if (e.getCause() instanceof ClusterAuthorizationException || e.getCause() instanceof TopicAuthorizationException) {
+                        if (e.getCause() instanceof ClusterAuthorizationException || e.getCause() instanceof TopicAuthorizationException || e.getCause() instanceof UnsupportedVersionException) {
                             return new HashMap<>();
                         }