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());