diff --git a/src/main/java/org/opencord/kafka/integrations/BngPppoeKafkaIntegration.java b/src/main/java/org/opencord/kafka/integrations/BngPppoeKafkaIntegration.java
index 17b7088..0cf49af 100644
--- a/src/main/java/org/opencord/kafka/integrations/BngPppoeKafkaIntegration.java
+++ b/src/main/java/org/opencord/kafka/integrations/BngPppoeKafkaIntegration.java
@@ -50,7 +50,7 @@
     protected volatile PppoeBngControlHandler ignore;
     private final AtomicReference<PppoeBngControlHandler> pppoeBngControlRef = new AtomicReference<>();
 
-    private static final String TOPIC_PPPOE = "bng.pppoe";
+    protected static final String TOPIC_PPPOE = "bng.pppoe";
     private static final String TIMESTAMP = "timestamp";
     private static final String EVENT_TYPE = "eventType";
     private static final String OLT_DEVICE_ID = "deviceId";