diff options
| author | tanghao <[email protected]> | 2024-08-20 09:33:32 +0800 |
|---|---|---|
| committer | tanghao <[email protected]> | 2024-08-20 09:33:32 +0800 |
| commit | 82dbe2bbbe77bed62cccf1b7e7659574276741a1 (patch) | |
| tree | 0ca6a28a395f2b0646638dbad9c857accb171497 | |
| parent | 9669573c78876f4a0c721bc539791f15d0435d17 (diff) | |
fix: 临时停止detection event数据处理
| -rw-r--r-- | cn-admin/src/main/java/net/geedge/common/config/DetectionRunner.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/cn-admin/src/main/java/net/geedge/common/config/DetectionRunner.java b/cn-admin/src/main/java/net/geedge/common/config/DetectionRunner.java index ad72054..41b1b5b 100644 --- a/cn-admin/src/main/java/net/geedge/common/config/DetectionRunner.java +++ b/cn-admin/src/main/java/net/geedge/common/config/DetectionRunner.java @@ -57,7 +57,7 @@ public class DetectionRunner implements CommandLineRunner{ @Override public void run(String... args) throws Exception { - Map<String, Event> cache = Context.DETECTTION_EVENT_CACHE; + /*Map<String, Event> cache = Context.DETECTTION_EVENT_CACHE; // 查询ck获取正在进行的event事件数据 更新到缓存中 queryEventDataToCache(cache); log.info("[DetectionRunner] [Get Event Data Cache] [Count : {}]",cache.size()); @@ -182,7 +182,7 @@ public class DetectionRunner implements CommandLineRunner{ } }finally { kafkaConsumer.close(); - } + }*/ } |
