diff --git a/lib/Config.js b/lib/Config.js index 5bcbea1a7..4deebf47e 100644 --- a/lib/Config.js +++ b/lib/Config.js @@ -146,11 +146,6 @@ class Config extends EventEmitter { }; } - // Overwrite logSource if configured - const configuredLogSource = process.env.BACKBEAT_QUEUEPOPULATOR_LOGSOURCE; - if (configuredLogSource) { - parsedConfig.queuePopulator.logSource = configuredLogSource; - } // Overwrite extension configs if configured // We can specify the list of extensions that should be handled by this // instance of the queuePopulator diff --git a/package.json b/package.json index 0043e0ec0..4b1a2480f 100644 --- a/package.json +++ b/package.json @@ -31,7 +31,7 @@ "lint": "eslint $(git ls-files '*.js')", "lint_md": "mdlint $(git ls-files '[^bucket-scanner/]*.md')", "start": "node bin/backbeat.js", - "notification_populator": "BACKBEAT_QUEUEPOPULATOR_EXTENSIONS=notification BACKBEAT_QUEUEPOPULATOR_LOGSOURCE=kafka node bin/queuePopulator.js", + "notification_populator": "BACKBEAT_QUEUEPOPULATOR_EXTENSIONS=notification node bin/queuePopulator.js", "notification_processor": "node extensions/notification/queueProcessor/task.js" }, "repository": {