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
});
});
};