diff --git a/src/main/java/org/opencord/kafka/integrations/DhcpL2RelayKafkaIntegration.java b/src/main/java/org/opencord/kafka/integrations/DhcpL2RelayKafkaIntegration.java
index 494635f..43153c3 100644
--- a/src/main/java/org/opencord/kafka/integrations/DhcpL2RelayKafkaIntegration.java
+++ b/src/main/java/org/opencord/kafka/integrations/DhcpL2RelayKafkaIntegration.java
@@ -62,8 +62,8 @@
     private final DhcpL2RelayListener listener = new InternalDhcpL2RelayListener();
 
     // topics
-    private static final String TOPIC = "dhcp.events";
-    private static final String DHCP_STATS_TOPIC = "onos.dhcp.stats.kpis";
+    protected static final String TOPIC = "dhcp.events";
+    protected static final String DHCP_STATS_TOPIC = "onos.dhcp.stats.kpis";
 
     private static final String TIMESTAMP = "timestamp";
     private static final String DEVICE_ID = "deviceId";