diff --git a/core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala b/core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala
index fef91ad36f2..1d0dfe019d8 100644
--- a/core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala
+++ b/core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala
@@ -323,7 +323,7 @@ class AbstractFetcherThreadTest {
     val mockTierStateMachine = new MockTierStateMachine(mockLeaderEndpoint)
     val fetcher = new MockFetcherThread(mockLeaderEndpoint, mockTierStateMachine)
 
-    // This test is contrived because it shouldn't be possible to to see unknown leader epoch
+    // This test is contrived because it shouldn't be possible to see unknown leader epoch
     // in the Fetching state as the leader must validate the follower's epoch when it checks
     // the truncation offset.
 
diff --git a/examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java b/examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java
index 15488c9c47d..175385b8ea8 100644
--- a/examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java
+++ b/examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java
@@ -227,7 +227,7 @@ public class ExactlyOnceMessageProcessor extends Thread implements ConsumerRebal
     /**
      * When we get a generic {@code KafkaException} while processing records, we retry up to {@code MAX_RETRIES} times.
      * If we exceed this threshold, we log an error and move on to the next batch of records.
-     * In a real world application you may want to to send these records to a dead letter topic (DLT) for further processing.
+     * In a real world application you may want to send these records to a dead letter topic (DLT) for further processing.
      * 
      * @param retries Current number of retries
      * @param consumer Consumer instance