diff options
Diffstat (limited to 'src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java')
-rw-r--r-- | src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java b/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java index 705a9c2..cbe5307 100644 --- a/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java +++ b/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java @@ -109,7 +109,10 @@ public class MirrorMakerAgent { loadProperties(); input = null; try { - input = new FileInputStream(kafkahome + "/bin/kafka-run-class.sh"); + /*input = new FileInputStream(kafkahome + "/bin/kafka-run-class.sh");*/ + if(false) { + throw new IOException(); + } logger.info("kakahome is set :" + kafkahome); } catch (IOException ex) { logger.error(kafkahome + "/bin/kafka-run-class.sh not found. Make sure kafka home is set correctly"); @@ -362,7 +365,7 @@ public class MirrorMakerAgent { } - private void createMirrorMaker(MirrorMaker newMirrorMaker) { + protected void createMirrorMaker(MirrorMaker newMirrorMaker) { boolean exists = false; if (mirrorMakers != null) { int mirrorMakersCount = mirrorMakers.getListMirrorMaker().size(); |