Merge pull request #518 from 0RAJA/feat_rule_audit_realtime

feat: 规则审计 - 事件实时生成风险 --story=120928201

src/backend/config/default.py

@@ -368,7 +368,7 @@
 # HDFS存储时长(天) -1 表示不限制
 DEFAULT_HDFS_STORAGE_EXPIRES = int(os.getenv("BKAPP_DEFAULT_HDFS_STORAGE_EXPIRES", -1))
 # 审计 kafka 配置
-KAFKA_CONFIG = json.loads(os.getenv("BKAPP_KAFKA_CONFIG", "{}"))
+KAFKA_CONFIG = json.loads(os.getenv("BKAPP_INIT_KAFKA_CONFIG", "{}"))
 # 事件 kafka 拉取超时时长
 EVENT_KAFKA_TIMEOUT_MS = int(os.getenv("BKAPP_EVENT_KAFKA_TIMEOUT_MS", 1000))
 # 事件 kafka 最大拉取记录数