From dda1b5a4e8e15188d0c0a09cbeab600c728cf335 Mon Sep 17 00:00:00 2001 From: Now <156046839+Kguswo@users.noreply.github.com> Date: Thu, 31 Jul 2025 00:59:49 +0900 Subject: [PATCH] MINOR: Fix duplicate 'to' in ExactlyOnceMessageProcessor javadoc (#20228) Fixed a simple typo in javadoc comment where "to to" appeared instead of "to". _No functional changes_ Reviewers: Chia-Ping Tsai --- .../scala/unit/kafka/server/AbstractFetcherThreadTest.scala | 2 +- .../main/java/kafka/examples/ExactlyOnceMessageProcessor.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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