diff --git a/src/main/java/org/opencord/kafka/integrations/AaaKafkaIntegration.java b/src/main/java/org/opencord/kafka/integrations/AaaKafkaIntegration.java
index 4d3a443..34699cb 100644
--- a/src/main/java/org/opencord/kafka/integrations/AaaKafkaIntegration.java
+++ b/src/main/java/org/opencord/kafka/integrations/AaaKafkaIntegration.java
@@ -94,9 +94,9 @@
             new InternalAaaMachineStatisticsListener();
 
     // topics
-    private static final String TOPIC = "authentication.events";
-    private static final String AUTHENTICATION_STATISTICS_TOPIC = "onos.aaa.stats.kpis";
-    private static final String RADIUS_OPERATION_STATUS_TOPIC = "radiusOperationalStatus.events";
+    protected static final String TOPIC = "authentication.events";
+    protected static final String AUTHENTICATION_STATISTICS_TOPIC = "onos.aaa.stats.kpis";
+    protected static final String RADIUS_OPERATION_STATUS_TOPIC = "radiusOperationalStatus.events";
     // auth event params
     private static final String TIMESTAMP = "timestamp";
     private static final String DEVICE_ID = "deviceId";