diff --git a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java index 483b54e5f430f..45a747e04daa4 100644 --- a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java +++ b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java @@ -3662,9 +3662,8 @@ public void testFetcherDontCacheAnyData() { LinkedHashMap responseData = fetchResponse.responseData(topicNames, version); assertEquals(topicNames.size(), responseData.size()); responseData.forEach((topicPartition, partitionData) -> assertEquals(records, partitionData.records())); - LinkedHashMap nonResponseData = fetchResponse.responseData(emptyMap(), version); - assertEquals(emptyMap().size(), nonResponseData.size()); - nonResponseData.forEach((topicPartition, partitionData) -> assertEquals(MemoryRecords.EMPTY, partitionData.records())); + LinkedHashMap nonResponseData = fetchResponse.responseData(Map.of(), version); + assertTrue(nonResponseData.isEmpty()); } private OffsetsForLeaderEpochResponse prepareOffsetsForLeaderEpochResponse(