启用 kafka

api/app/lib/index.js

@@ -23,7 +23,7 @@ module.exports.entry = function (app, router, opts) {
    app.fs.utils = app.fs.utils || {};
    app.fs.api.authAttr = app.fs.api.authAttr || {};
    app.fs.api.logAttr = app.fs.api.logAttr || {};
-  
+
 
    // 顺序固定 ↓ 
    redisConnect(app, opts)
@@ -35,7 +35,7 @@ module.exports.entry = function (app, router, opts) {
 
    es(app, opts)
 
-   // kafka(app, opts)
+   kafka(app, opts)
 
    // clickHouse 数据库 client 
    clickHouseClient(app, opts)
@@ -55,7 +55,7 @@ module.exports.entry = function (app, router, opts) {
 
    router = routes(app, router, opts);
 
-    
+
 };
 
 module.exports.models = function (dc) { // dc = { orm: Sequelize对象, ORM: Sequelize, models: {} }
@@ -69,7 +69,7 @@ module.exports.models = function (dc) { // dc = { orm: Sequelize对象, ORM: Seq
       AppInspection, ProjectApp, ProjectCorrelation, AppAlarm, App, AlarmAppearRecord, AlarmConfirmLog, EmailSendLog, LatestDynamicList, AlarmPushConfig,
       MaintenanceRecord, MaintenanceRecordExecuteUser, MaintenancePlanExecuteUser, MaintenancePlan, EquipmentMaintenanceRecord, EquipmentMaintenanceRecordProject,
       EquipmentMaintenanceRecordExecuteUser, ServerMaintenanceRecordRepairman, ServerMaintenanceRecord,
-      AlarmDataContinuityType, AlarmDataContinuity,AbnTypes,AbnReportParams
+      AlarmDataContinuityType, AlarmDataContinuity, AbnTypes, AbnReportParams
    } = dc.models;
 
    AppInspection.belongsTo(App, { foreignKey: 'projectAppId', targetKey: 'id' });