|
|
@ -12,12 +12,12 @@ module.exports = async function factory(app, opts) { |
|
|
|
console.log('111111 ready 666666666666') |
|
|
|
}) |
|
|
|
|
|
|
|
// const kafka = {
|
|
|
|
// producer: producer,
|
|
|
|
// configUpdateMessage: opts.configUpdateMessage || {}
|
|
|
|
// };
|
|
|
|
const kafka = { |
|
|
|
producer: producer, |
|
|
|
configUpdateMessage: opts.configUpdateMessage || {} |
|
|
|
}; |
|
|
|
|
|
|
|
// app.fs.kafka = kafka;
|
|
|
|
app.fs.kafka = kafka; |
|
|
|
app.fs.logger.log('debug', "[FS-KAFKA]", "Init.Success"); |
|
|
|
|
|
|
|
|
|
|
|