diff --git a/streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractKeyValueStoreTest.java b/streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractKeyValueStoreTest.java index 3284b177f776f..5959a8079106d 100644 --- a/streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractKeyValueStoreTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractKeyValueStoreTest.java @@ -260,7 +260,7 @@ public void testPutGetWithDefaultSerdes() { assertEquals("one", driver.flushedEntryStored(1)); assertEquals("two", driver.flushedEntryStored(2)); assertEquals("four", driver.flushedEntryStored(4)); - assertNull(null, driver.flushedEntryStored(5)); + assertNull(driver.flushedEntryStored(5)); assertFalse(driver.flushedEntryRemoved(0)); assertFalse(driver.flushedEntryRemoved(1));