input = new FileInputStream(mmagenthome + "/etc/mmagent.config");
logger.info("mmagenthome is set :" + mmagenthome + " loading properties at /etc/mmagent.config");
} catch (IOException ex) {
input = new FileInputStream(mmagenthome + "/etc/mmagent.config");
logger.info("mmagenthome is set :" + mmagenthome + " loading properties at /etc/mmagent.config");
} catch (IOException ex) {
} catch (IOException ex) {
logger.error(kafkahome + "/bin/kafka-run-class.sh not found. Make sure kafka home is set correctly");
return false;
} catch (IOException ex) {
logger.error(kafkahome + "/bin/kafka-run-class.sh not found. Make sure kafka home is set correctly");
return false;
- response = topicUtil.subscribeTopic(topicURL, topicname, "1", response, response);
+ response = topicUtil.subscribeTopic(topicURL, topicname, "1", mechid, password);
if (response != null && response.startsWith("ERROR:")) {
logger.error("Problem subscribing to topic, please verify the config " + this.topicname + " MR URL is:"
+ this.topicURL + " Error is: " + response);
if (response != null && response.startsWith("ERROR:")) {
logger.error("Problem subscribing to topic, please verify the config " + this.topicname + " MR URL is:"
+ this.topicURL + " Error is: " + response);