diff --git a/src/main/java/kafka/VolthaKafkaConsumer.java b/src/main/java/kafka/VolthaKafkaConsumer.java
index 11deb81..ba121e6 100644
--- a/src/main/java/kafka/VolthaKafkaConsumer.java
+++ b/src/main/java/kafka/VolthaKafkaConsumer.java
@@ -49,10 +49,12 @@
 
     private KafkaConsumerType type;
 
+    private VesAgent vesAgent;
+
     public VolthaKafkaConsumer(KafkaConsumerType type) {
         logger.debug("VolthaKafkaConsumer constructor called");
-        initVesAgent();
         this.type = type;
+        vesAgent = new VesAgent();
         try {
             consumer = createConsumer();
         } catch (Exception e) {
@@ -62,10 +64,6 @@
         }
     }
 
-    private void initVesAgent() {
-        VesAgent.initVes();
-    }
-
     private KafkaConsumer<Long, String> createConsumer() {
         logger.debug("Creating Kafka Consumer");
 
@@ -124,7 +122,7 @@
                     record.key(), record.value(),
                     record.partition(), record.offset());
                     logger.info("Attempting to send data to VES");
-                    boolean success = VesAgent.sendToVES(type, record.value());
+                    boolean success = vesAgent.sendToVES(type, record.value());
                     if (!success) {
                         throw new HTTPException(0);
                     } else {