diff options
| author |   varun gudisena <varuneshwar.gudisena@att.com> | 2019-02-07 21:29:43 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2019-02-07 21:29:43 +0000 |
| commit | 0b7a478ae5ab094b9cc39d7dcc1c64cac2b16255 (patch) | |
| tree | 44841c04b62f65c5fa69d20a172b9ebb920190b9 | |
| parent | 89fd34e909a6864f568ffb76218e8903144c88cd (diff) | |
| parent | edb57cc44d6e84f8e83205c792a6484882343b8e (diff) | |
Merge "update the shell script"
| -rw-r--r-- | src/main/java/org/onap/dmaap/mr/dmaapMMAgent/utils/MirrorMakerProcessHandler.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/main/java/org/onap/dmaap/mr/dmaapMMAgent/utils/MirrorMakerProcessHandler.java b/src/main/java/org/onap/dmaap/mr/dmaapMMAgent/utils/MirrorMakerProcessHandler.java index 114d1f8..9b5f863 100644 --- a/src/main/java/org/onap/dmaap/mr/dmaapMMAgent/utils/MirrorMakerProcessHandler.java +++ b/src/main/java/org/onap/dmaap/mr/dmaapMMAgent/utils/MirrorMakerProcessHandler.java @@ -171,8 +171,8 @@ public class MirrorMakerProcessHandler { String args[] = { "/bin/sh", "-c", kafkaHome + "/bin/kafka-run-class.sh -Dagentname=" + agentName + " kafka.tools.MirrorMaker --consumer.config " + consumerConfig - + " --producer.config " + producerConfig + " --num.streams " + numStreams + " --abort.on.send.failure true" + " --whitelist '" + whitelist + "' 2>&1 >" - + mmagenthome + "/logs/" + agentName + "_MMaker.log " }; + + " --producer.config " + producerConfig + " --num.streams " + numStreams + " --abort.on.send.failure true" + " --whitelist '" + whitelist + "' >" + + mmagenthome + "/logs/" + agentName + "_MMaker.log 2>&1" }; final Process process = rt.exec(args); new Thread() { public void run() { |