feat(backend): kafka支持消费组延迟自定义条件 #3685

TencentBlueKing · Mar 25, 2024 · 5da1a52 · 5da1a52
1 parent b531feb
commit 5da1a52
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/dbm-ui/backend/db_monitor/tpls/alarm/kafka/Kafka 消费组延迟.json b/dbm-ui/backend/db_monitor/tpls/alarm/kafka/Kafka 消费组延迟.json
@@ -272,7 +272,6 @@
     {
       "key": "consumergroup",
       "value": [
-        "gsin"
       ],
       "method": "eq",
       "condition": "and",
@@ -281,7 +280,6 @@
     {
       "key": "topic",
       "value": [
-        "sinsin"
       ],
       "method": "eq",
       "condition": "and",

diff --git a/dbm-ui/backend/db_periodic_task/local_tasks/db_monitor.py b/dbm-ui/backend/db_periodic_task/local_tasks/db_monitor.py
@@ -85,7 +85,7 @@ def sync_plat_monitor_policy():
             dirs.remove(skip_dir)
 
         for alarm_tpl in files:
-            with open(os.path.join(root, alarm_tpl), "r") as f:
+            with open(os.path.join(root, alarm_tpl), "r", encoding="utf-8") as f:
                 try:
                     template_dict = json.loads(f.read())
                     policy_name = template_dict["name"]