Add logger.

src/main/java/com/hpcloud/event/MetricMessageEventHandler.java

@@ -6,6 +6,8 @@ import com.hpcloud.message.MetricMessage;
 import com.hpcloud.repository.VerticaMetricRepository;
 import com.lmax.disruptor.EventHandler;
 import org.apache.commons.codec.digest.DigestUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.text.SimpleDateFormat;
 import java.util.Date;
@@ -13,6 +15,8 @@ import java.util.TimeZone;
 
 public class MetricMessageEventHandler implements EventHandler<MetricMessageEvent> {
 
+    private static final Logger logger = LoggerFactory.getLogger(MetricMessageEventHandler.class);
+
     private final int ordinal;
     private final int numProcessors;
     private final int batchSize;
@@ -40,14 +44,14 @@ public class MetricMessageEventHandler implements EventHandler<MetricMessageEven
     @Override
     public void onEvent(MetricMessageEvent metricMessageEvent, long sequence, boolean b) throws Exception {
 
-        System.out.println("Sequence number: " + sequence +
-                " Ordinal: " + ordinal +
-                " Event: " + metricMessageEvent.getMetricMessage());
-
         if (((sequence / batchSize) % this.numProcessors) != this.ordinal) {
             return;
         }
 
+        logger.info("Sequence number: " + sequence +
+                " Ordinal: " + ordinal +
+                " Event: " + metricMessageEvent.getMetricMessage());
+
         MetricMessage metricMessage = metricMessageEvent.getMetricMessage();
 
         String stringToHash = metricMessage.getName() + metricMessage.getRegion() + metricMessage.getTenant();

src/main/resources/com/hpcloud/mon-persister-config.yml

@@ -4,7 +4,7 @@ name: mon-persister
 kafkaConfiguration:
 # See http://kafka.apache.org/documentation.html#api for semantics and defaults.
   topic: test
-  numThreads: 4
+  numThreads: 2
   groupId: 1
   zookeeperConnect: localhost:2181
   consumerId: 1
@@ -28,10 +28,10 @@ kafkaConfiguration:
 
 disruptorConfiguration:
   bufferSize:  1048576
-  numProcessors: 4
+  numProcessors: 2
 
 verticaOutputProcessorConfiguration:
-  batchSize: 100
+  batchSize: 50000
 
 monDeDuperConfiguration:
   dedupeRunFrequencySeconds: 30
@@ -74,7 +74,7 @@ logging:
 
   # The default level of all loggers. Can be OFF, ERROR, WARN, INFO,
   # DEBUG, TRACE, or ALL.
-  level: DEBUG
+  level: INFO
 
   # Logger-specific levels.
   loggers: