From fa42389248505122f8a8eefe8f12f403df29404c Mon Sep 17 00:00:00 2001
From: Steve Tarzia <steve@stevetarzia.com>
Date: Thu, 18 Sep 2014 12:21:41 -0500
Subject: [PATCH] removed bad assertion test (it depends on timing)

---
 .../test/java/com/netflix/suro/sink/kafka/TestKafkaSinkV2.java   | 1 -
 1 file changed, 1 deletion(-)

diff --git a/suro-kafka/src/test/java/com/netflix/suro/sink/kafka/TestKafkaSinkV2.java b/suro-kafka/src/test/java/com/netflix/suro/sink/kafka/TestKafkaSinkV2.java
index ebbc9e14..2f9b567f 100644
--- a/suro-kafka/src/test/java/com/netflix/suro/sink/kafka/TestKafkaSinkV2.java
+++ b/suro-kafka/src/test/java/com/netflix/suro/sink/kafka/TestKafkaSinkV2.java
@@ -78,7 +78,6 @@ public void testDefaultParameters() throws IOException {
             sink.writeTo(next); // send
             sentPayloads.add( new String( next.getMessage().getPayload() ) ); // record
         }
-        assertTrue(sink.getNumOfPendingMessages() > 0);
         sink.close();
         assertEquals(sink.getNumOfPendingMessages(), 0);
         System.out.println(sink.getStat());