mirror of
https://github.com/didi/KnowStreaming.git
synced 2025-12-24 03:42:07 +08:00
d1417bef8c
原因： 首先，删除Kafka集群后，没有将DB中的Connect集群进行删除。随后，进行Connect集群指标采集时，由于所在的Kafka集群已经不存在了。最终，导致NPE； 解决： 发布一个Kafka集群删除事件，触发MetaDataService子类，将其在DB中的数据进行删除。 遗留： 当前MetaDataService仅在部分元信息同步类中实现，导致当前DB中的脏数据清理不彻底，后续等MetaDataService在所有元信息同步类中实现后，便可彻底清理数据。 PS：当前修复已保证NPE问题不会再出现。