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());
diff --git a/storage/src/main/java/org/apache/kafka/storage/internals/epoch/LeaderEpochFileCache.java b/storage/src/main/java/org/apache/kafka/storage/internals/epoch/LeaderEpochFileCache.java
index 49a97f6c0d16c..fe098229f3917 100644
--- a/storage/src/main/java/org/apache/kafka/storage/internals/epoch/LeaderEpochFileCache.java
+++ b/storage/src/main/java/org/apache/kafka/storage/internals/epoch/LeaderEpochFileCache.java
@@ -47,7 +47,7 @@
  * Offset = offset of the first message in each epoch.
  * <p>
  * Note that {@link #truncateFromStartAsyncFlush},{@link #truncateFromEndAsyncFlush} flush the epoch-entry changes to checkpoint asynchronously.
- * Hence, it is instantiater's responsibility to ensure restoring the cache to the correct state after instantiating
+ * Hence, it is instantiator's responsibility to ensure restoring the cache to the correct state after instantiating
  * this class from checkpoint (which might contain stale epoch entries right after instantiation).
  */
 public final class LeaderEpochFileCache {