21 lines
415 B
21 lines
415 B
'use strict';
|
|
|
|
module.exports = function (app, opts) {
|
|
|
|
async function kfkSendAsync (payloads) {
|
|
const { producer } = app.fs.kafka
|
|
return new Promise((resolve, reject) => {
|
|
producer.send(payloads, function (err) {
|
|
if (err) {
|
|
reject(err);
|
|
} else {
|
|
resolve();
|
|
}
|
|
});
|
|
})
|
|
}
|
|
|
|
return {
|
|
kfkSendAsync
|
|
}
|
|
}
|