fix

tchiotludo · Nov 6, 2022 · 375e5c3 · 375e5c3
1 parent 7cfc7d2
commit 375e5c3
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/client/src/containers/Node/NodeList/NodesList.jsx b/client/src/containers/Node/NodeList/NodesList.jsx
@@ -37,7 +37,7 @@ class NodesList extends Root {
         id: JSON.stringify(node.id) || '',
         host: `${node.host}:${node.port}` || '',
         rack: node.rack || '',
-        controller: nodes.controller.id === node.id ? 'True' : 'False' || '',
+        controller: nodes.controller && nodes.controller.id === node.id ? 'True' : 'False' || '',
         partition: undefined
       };
     });

diff --git a/src/main/java/org/akhq/models/Cluster.java b/src/main/java/org/akhq/models/Cluster.java
@@ -26,8 +26,9 @@ public Cluster(DescribeClusterResult result) throws ExecutionException, Interrup
             this.nodes.add(new Node(node));
         }
 
-        Optional.ofNullable(result.controller().get()).ifPresentOrElse(
-            node -> this.controller = new Node(node),
-            () -> this.controller = new Node());
+        /*
+        if (result.controller().get() != null) {
+            this.controller = new Node(result.controller().get());
+        }*/
     }
 }