in action/messageHubFeedWeb.js [220:264]
function validateMessageHubParameters(rawParams) {
var promise = new Promise((resolve, reject) => {
var validatedParams = {};
// kafka_brokers_sasl
if (rawParams.kafka_brokers_sasl) {
validatedParams.brokers = common.validateBrokerParam(rawParams.kafka_brokers_sasl);
if (!validatedParams.brokers) {
reject( { validationError: "You must supply a 'kafka_brokers_sasl' parameter as an array of Message Hub brokers." });
return;
}
} else {
reject( { validationError: "You must supply a 'kafka_brokers_sasl' parameter." });
return;
}
// user
if (rawParams.user) {
validatedParams.username = rawParams.user;
} else {
reject( { validationError: "You must supply a 'user' parameter to authenticate with Message Hub." });
return;
}
// password
if (rawParams.password) {
validatedParams.password = rawParams.password;
} else {
reject( { validationError: "You must supply a 'password' parameter to authenticate with Message Hub." });
return;
}
// kafka_admin_url
if (rawParams.kafka_admin_url) {
validatedParams.kafka_admin_url = rawParams.kafka_admin_url;
} else {
reject( { validationError: "You must supply a 'kafka_admin_url' parameter." });
return;
}
resolve(validatedParams);
});
return promise;
}