VOL-2710: Add unit test cases for kafka-onos

Change-Id: Ieff0a32b3552eb8843fa933e57fa4148cb54853b
diff --git a/src/main/java/org/opencord/kafka/integrations/McastKafkaIntegration.java b/src/main/java/org/opencord/kafka/integrations/McastKafkaIntegration.java
index 8712333..1574c7f 100644
--- a/src/main/java/org/opencord/kafka/integrations/McastKafkaIntegration.java
+++ b/src/main/java/org/opencord/kafka/integrations/McastKafkaIntegration.java
@@ -55,7 +55,7 @@
     private final CordMcastStatisticsEventListener cordMcastStatisticsEventListener =
             new InternalCorcMcastStatisticsListener();
 
-    private static final String MCAST_OPERATIONAL_STATUS_TOPIC = "mcastOperationalStatus.events";
+    protected static final String MCAST_OPERATIONAL_STATUS_TOPIC = "mcastOperationalStatus.events";
 
     //cord mcast stats event params
     private static final String TIMESTAMP = "timestamp";