'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
   }
}