8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2025-12-24 03:42:07 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

[Bugfix]集群JMX配置发生变更时，进行JMX的重新加载

Browse Source
This commit is contained in:
zengqiao
2022-11-10 16:04:40 +08:00
parent da0a97cabf
commit e456be91ef
1 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaJMXClient.java
View File

@@ -45,10 +45,6 @@ public class KafkaJMXClient extends AbstractClusterLoadedChangedHandler {
public JmxConnectorWrap getClient(Long clusterPhyId, Integer brokerId) {
Map<Integer, JmxConnectorWrap> 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;
}