summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authortanghao <[email protected]>2024-08-20 09:33:32 +0800
committertanghao <[email protected]>2024-08-20 09:33:32 +0800
commit82dbe2bbbe77bed62cccf1b7e7659574276741a1 (patch)
tree0ca6a28a395f2b0646638dbad9c857accb171497
parent9669573c78876f4a0c721bc539791f15d0435d17 (diff)
fix: 临时停止detection event数据处理
-rw-r--r--cn-admin/src/main/java/net/geedge/common/config/DetectionRunner.java4
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();
- }
+ }*/
}