Merge "changes for kafka upgrade"

[dmaap/messagerouter/mirroragent.git] / src / main / java / com / att / nsa / dmaapMMAgent / utils / MirrorMakerProcessHandler.java

diff --git a/src/main/java/com/att/nsa/dmaapMMAgent/utils/MirrorMakerProcessHandler.java b/src/main/java/com/att/nsa/dmaapMMAgent/utils/MirrorMakerProcessHandler.java
index e4a0b97..215323e 100644 (file)
--- a/src/main/java/com/att/nsa/dmaapMMAgent/utils/MirrorMakerProcessHandler.java
+++ b/src/main/java/com/att/nsa/dmaapMMAgent/utils/MirrorMakerProcessHandler.java
@@ -152,6 +152,7 @@ public class MirrorMakerProcessHandler {/*
                                                + "_MMaker.log";
                                final Process process = rt.exec(args);
                                new Thread() {
+                                       @Override
                                        public void run() {
                                                try {
                                                        InputStream is = process.getInputStream();