From e456be91ef0b69e610a038ad1381710b46aee182 Mon Sep 17 00:00:00 2001 From: zengqiao Date: Thu, 10 Nov 2022 16:04:40 +0800 Subject: [PATCH] =?UTF-8?q?[Bugfix]=E9=9B=86=E7=BE=A4JMX=E9=85=8D=E7=BD=AE?= =?UTF-8?q?=E5=8F=91=E7=94=9F=E5=8F=98=E6=9B=B4=E6=97=B6=EF=BC=8C=E8=BF=9B?= =?UTF-8?q?=E8=A1=8CJMX=E7=9A=84=E9=87=8D=E6=96=B0=E5=8A=A0=E8=BD=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../streaming/km/persistence/kafka/KafkaJMXClient.java | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaJMXClient.java b/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaJMXClient.java index 39ae1ebe..1ee0adcb 100644 --- a/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaJMXClient.java +++ b/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaJMXClient.java @@ -45,10 +45,6 @@ public class KafkaJMXClient extends AbstractClusterLoadedChangedHandler { public JmxConnectorWrap getClient(Long clusterPhyId, Integer brokerId) { Map jmxMap = JMX_MAP.getOrDefault(clusterPhyId, new ConcurrentHashMap<>()); - if (jmxMap == null) { - // 集群不存在, 直接返回null - return null; - } JmxConnectorWrap jmxConnectorWrap = jmxMap.get(brokerId); if (jmxConnectorWrap != null) { @@ -107,7 +103,8 @@ public class KafkaJMXClient extends AbstractClusterLoadedChangedHandler { protected void modify(ClusterPhy newClusterPhy, ClusterPhy oldClusterPhy) { if (newClusterPhy.getClientProperties().equals(oldClusterPhy.getClientProperties()) && newClusterPhy.getZookeeper().equals(oldClusterPhy.getZookeeper()) - && newClusterPhy.getBootstrapServers().equals(oldClusterPhy.getBootstrapServers())) { + && newClusterPhy.getBootstrapServers().equals(oldClusterPhy.getBootstrapServers()) + && newClusterPhy.getJmxProperties().equals(oldClusterPhy.getJmxProperties())) { // 集群信息虽然变化，但是相关没有变化，则直接返回 return; }