Skip to content

Commit dda1b5a

Browse files
authored
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 <chia7712@gmail.com>
1 parent 1bcaa19 commit dda1b5a

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -323,7 +323,7 @@ class AbstractFetcherThreadTest {
323323
val mockTierStateMachine = new MockTierStateMachine(mockLeaderEndpoint)
324324
val fetcher = new MockFetcherThread(mockLeaderEndpoint, mockTierStateMachine)
325325

326-
// This test is contrived because it shouldn't be possible to to see unknown leader epoch
326+
// This test is contrived because it shouldn't be possible to see unknown leader epoch
327327
// in the Fetching state as the leader must validate the follower's epoch when it checks
328328
// the truncation offset.
329329

examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -227,7 +227,7 @@ private long getRemainingRecords(KafkaConsumer<Integer, String> consumer) {
227227
/**
228228
* When we get a generic {@code KafkaException} while processing records, we retry up to {@code MAX_RETRIES} times.
229229
* If we exceed this threshold, we log an error and move on to the next batch of records.
230-
* In a real world application you may want to to send these records to a dead letter topic (DLT) for further processing.
230+
* In a real world application you may want to send these records to a dead letter topic (DLT) for further processing.
231231
*
232232
* @param retries Current number of retries
233233
* @param consumer Consumer instance

0 commit comments

Comments
 (0)