function getMskBootstrapBrokers()

in function-documentdb-stream-processor/index.js [105:122]


function getMskBootstrapBrokers () {
    const kafkaSdk = new AWS.Kafka();
    return new Promise ((resolve,reject) => {
      var params = {
        ClusterArn: process.env.MSK_BROKER_ARN
      };
      kafkaSdk.getBootstrapBrokers(params, function(err, data) {
        if (err) {
        console.log(err);
        reject(err);
         }// an error occurred
        else  {
          console.log(data);
          resolve(data);
        } // successful response
      });
});
};