root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 5 Packages Projects Releases Wiki Activity

MINOR: Fix duplicate 'to' in ExactlyOnceMessageProcessor javadoc (#20228)
CI / build (push) Waiting to run Details 

Fixed a simple typo in javadoc comment where "to to" appeared instead of
"to".

_No functional changes_

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
Now 2025-07-31 00:59:49 +09:00 committed by GitHub
parent 1bcaa19c46
commit dda1b5a4e8
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala
View File

@ -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.

2
examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java
View File

@ -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