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

MINOR: Fix typo and docs (#20373) 

Fix typo and docs in following.
```
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java
clients/src/main/resources/common/message/FetchRequest.json
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
```

Reviewers: Kuan-Po Tseng <brandboat@gmail.com>, Lan Ding
 <isDing_L@163.com>, Ken Huang <s7133700@gmail.com>, TengYao Chi
 <kitingiao@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>, PoAn Yang
 <payang@apache.org>
This commit is contained in:
Chih-Yuan Chien 2025-08-19 19:04:41 +08:00 committed by GitHub
parent 656242775c
commit 38c3a411e9
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java
View File

@ -18,7 +18,6 @@ package org.apache.kafka.clients.consumer;
import org.apache.kafka.common.TopicPartition;
import java.time.Duration;
import java.util.Collection;
/**
@ -121,7 +120,7 @@ public interface ConsumerRebalanceListener {
/**
* A callback method the user can implement to provide handling of offset commits to a customized store.
* This method will be called during a rebalance operation when the consumer has to give up some partitions.
* It can also be called when consumer is being closed ({@link KafkaConsumer#close(Duration)})
* It can also be called when consumer is being closed ({@link KafkaConsumer#close(CloseOptions option)})
* or is unsubscribing ({@link KafkaConsumer#unsubscribe()}).
* It is recommended that offsets should be committed in this callback to either Kafka or a
* custom offset store to prevent duplicate data.

2
clients/src/main/resources/common/message/FetchRequest.json
View File

@ -27,7 +27,7 @@
// the request is now relevant. Partitions will be processed in the order
// they appear in the request.
//
// Version 4 adds IsolationLevel. Starting in version 4, the reqestor must be
// Version 4 adds IsolationLevel. Starting in version 4, the requestor must be
// able to handle Kafka log message format version 2.
//
// Version 5 adds LogStartOffset to indicate the earliest available offset of

4
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
View File

@ -3145,7 +3145,7 @@ public final class KafkaRaftClient<T> implements RaftClient<T> {
return 0L;
}
long timeUtilVoterChangeExpires = state.maybeExpirePendingOperation(currentTimeMs);
long timeUntilVoterChangeExpires = state.maybeExpirePendingOperation(currentTimeMs);
long timeUntilFlush = maybeAppendBatches(
state,
@ -3163,7 +3163,7 @@ public final class KafkaRaftClient<T> implements RaftClient<T> {
timeUntilNextBeginQuorumSend,
Math.min(
timeUntilCheckQuorumExpires,
timeUtilVoterChangeExpires
timeUntilVoterChangeExpires
)
)
);