changes for kafka upgrade

Issue-ID: DMAAP-513
Change-Id: I614ff2919e28c3194eab6bb731d076d9c91be1d7
Signed-off-by: sunil unnava <su622b@att.com>

1 files changed, 18 insertions, 1 deletions

diff --git a/src/main/java/com/att/nsa/dmaapMMAgent/dao/MirrorMaker.java b/src/main/java/com/att/nsa/dmaapMMAgent/dao/MirrorMaker.java
index 61426c9..cdf6584 100644
--- a/src/main/java/com/att/nsa/dmaapMMAgent/dao/MirrorMaker.java
+++ b/src/main/java/com/att/nsa/dmaapMMAgent/dao/MirrorMaker.java
@@ -19,7 +19,6 @@
  *  ECOMP is a trademark and service mark of AT&T Intellectual Property.
  *  
  *******************************************************************************/
- 
 package com.att.nsa.dmaapMMAgent.dao;
 
 public class MirrorMaker {
@@ -28,6 +27,8 @@ public class MirrorMaker {
 	public String producer;
 	public String whitelist;
 	public String status;
+	public int numStreams=1;
+	public boolean enablelogCheck = false;
 
 	public String getStatus() {
 		return status;
@@ -69,4 +70,20 @@ public class MirrorMaker {
 		this.whitelist = whitelist;
 	}
 
+	public int getNumStreams() {
+		return numStreams;
+	}
+
+	public void setNumStreams(int numStreams) {
+		this.numStreams = numStreams;
+	}
+
+	public boolean isEnablelogCheck() {
+		return enablelogCheck;
+	}
+
+	public void setEnablelogCheck(boolean enablelogCheck) {
+		this.enablelogCheck = enablelogCheck;
+	}
+
 }
\ No newline at end of file