From 375e5c35a7bf3b28757925a70f365487f02a4a73 Mon Sep 17 00:00:00 2001 From: Ludovic DEHON Date: Sun, 6 Nov 2022 21:15:48 +0100 Subject: [PATCH] fix --- client/src/containers/Node/NodeList/NodesList.jsx | 2 +- src/main/java/org/akhq/models/Cluster.java | 7 ++++--- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/client/src/containers/Node/NodeList/NodesList.jsx b/client/src/containers/Node/NodeList/NodesList.jsx index fdbc5ed1f..759cf7150 100644 --- 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 index 8f51166c2..cdbf07f83 100644 --- 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()); + }*/ } }