From 50f88a83b56dcf61362fd51d7cbdf4b1a6bc8a82 Mon Sep 17 00:00:00 2001 From: RonGamzu Date: Sat, 23 May 2026 22:04:45 +0300 Subject: [PATCH] Fix typo 'amd' -> 'and' in CompletableEventReaperTest comments Three identical test comments in CompletableEventReaperTest contained the typo 'amd' where 'and' was intended. Fixed all three occurrences in testExpired, testCompleted, and testCompletedAndExpired. --- .../internals/events/CompletableEventReaperTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/events/CompletableEventReaperTest.java b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/events/CompletableEventReaperTest.java index 6b7e1855cbd04..e9e9aaf163206 100644 --- a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/events/CompletableEventReaperTest.java +++ b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/events/CompletableEventReaperTest.java @@ -47,7 +47,7 @@ public void testExpired() { UnsubscribeEvent event = new UnsubscribeEvent(calculateDeadlineMs(time.milliseconds(), timeoutMs)); reaper.add(event); - // Without any time passing, we check the reaper and verify that the event is not done amd is still + // Without any time passing, we check the reaper and verify that the event is not done and is still // being tracked. assertEquals(0, reaper.reap(time.milliseconds())); assertFalse(event.future().isDone()); @@ -75,7 +75,7 @@ public void testCompleted() { UnsubscribeEvent event = new UnsubscribeEvent(calculateDeadlineMs(time.milliseconds(), timeoutMs)); reaper.add(event); - // Without any time passing, we check the reaper and verify that the event is not done amd is still + // Without any time passing, we check the reaper and verify that the event is not done and is still // being tracked. assertEquals(0, reaper.reap(time.milliseconds())); assertFalse(event.future().isDone()); @@ -106,7 +106,7 @@ public void testCompletedAndExpired() { reaper.add(event1); reaper.add(event2); - // Without any time passing, we check the reaper and verify that the event is not done amd is still + // Without any time passing, we check the reaper and verify that the event is not done and is still // being tracked. assertEquals(0, reaper.reap(time.milliseconds())); assertFalse(event1.future().isDone());