@orion-js/echoes
Advanced tools
Comparing version 2.2.1 to 2.2.2
@@ -18,9 +18,11 @@ "use strict"; | ||
async function _default(options) { | ||
function _default(options) { | ||
const kafka = new _kafkajs.Kafka(options.client); | ||
_config.default.producer = kafka.producer(options.producer); | ||
_config.default.consumer = kafka.consumer(options.consumer); | ||
await _config.default.producer.connect(); | ||
await _config.default.consumer.connect(); | ||
_config.default.producer.connect(); | ||
_config.default.consumer.connect(); | ||
for (const topic in options.echoes) { | ||
@@ -27,0 +29,0 @@ _config.default.consumer.subscribe({ |
{ | ||
"name": "@orion-js/echoes", | ||
"version": "2.2.1", | ||
"version": "2.2.2", | ||
"main": "lib/index.js", | ||
@@ -31,3 +31,3 @@ "author": "nicolaslopezj", | ||
}, | ||
"gitHead": "60107059b7c8ebe1ef8cab2992ac528263d425b5" | ||
"gitHead": "c9b52f3479dfebfecc5d33621fb066ea137b785b" | ||
} |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
122915