diff --git a/src/main/java/org/opencord/kafka/integrations/IgmpKafkaIntegration.java b/src/main/java/org/opencord/kafka/integrations/IgmpKafkaIntegration.java
index 4da7e43..c424d67 100644
--- a/src/main/java/org/opencord/kafka/integrations/IgmpKafkaIntegration.java
+++ b/src/main/java/org/opencord/kafka/integrations/IgmpKafkaIntegration.java
@@ -58,7 +58,7 @@
             new InternalIgmpStatisticsListener();
 
     //TOPIC
-    private static final String IGMP_STATISTICS_TOPIC = "onos.igmp.stats.kpis";
+    protected static final String IGMP_STATISTICS_TOPIC = "onos.igmp.stats.kpis";
 
     // IGMP stats event params
     private static final String IGMP_JOIN_REQ = "igmpJoinReq";