Merge pull request #25 from uber/fix_empty_posts

Fix to prevent empty messages from being posted
uber-archive · Dec 8, 2015 · 365fd93 · 365fd93
2 parents 1ef2968 + b5a05c0
commit 365fd93
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/main/java/com/uber/kafkaSpraynozzle/KafkaPoster.java b/src/main/java/com/uber/kafkaSpraynozzle/KafkaPoster.java
@@ -163,6 +163,10 @@ public void run() {
     }
 
     private boolean postBatchEvents(List<ByteArrayEntity> batch) {
+        if (batch.isEmpty()) {
+            return true;
+        }
+
         final long NANOS_PER_SECOND = 1000L * 1000L * 1000L;
         final long NANOS_PER_MILLI_SECOND = 1000L * 1000L;
         int pickedUrlIdx = currentUrl;