File tree Expand file tree Collapse file tree 3 files changed +4
-5
lines changed
java/org/apache/kafka/clients/consumer
raft/src/main/java/org/apache/kafka/raft Expand file tree Collapse file tree 3 files changed +4
-5
lines changed Original file line number Diff line number Diff line change 18
18
19
19
import org .apache .kafka .common .TopicPartition ;
20
20
21
- import java .time .Duration ;
22
21
import java .util .Collection ;
23
22
24
23
/**
@@ -121,7 +120,7 @@ public interface ConsumerRebalanceListener {
121
120
/**
122
121
* A callback method the user can implement to provide handling of offset commits to a customized store.
123
122
* This method will be called during a rebalance operation when the consumer has to give up some partitions.
124
- * It can also be called when consumer is being closed ({@link KafkaConsumer#close(Duration )})
123
+ * It can also be called when consumer is being closed ({@link KafkaConsumer#close(CloseOptions option )})
125
124
* or is unsubscribing ({@link KafkaConsumer#unsubscribe()}).
126
125
* It is recommended that offsets should be committed in this callback to either Kafka or a
127
126
* custom offset store to prevent duplicate data.
Original file line number Diff line number Diff line change 27
27
// the request is now relevant. Partitions will be processed in the order
28
28
// they appear in the request.
29
29
//
30
- // Version 4 adds IsolationLevel. Starting in version 4, the reqestor must be
30
+ // Version 4 adds IsolationLevel. Starting in version 4, the requestor must be
31
31
// able to handle Kafka log message format version 2.
32
32
//
33
33
// Version 5 adds LogStartOffset to indicate the earliest available offset of
Original file line number Diff line number Diff line change @@ -3145,7 +3145,7 @@ private long pollLeader(long currentTimeMs) {
3145
3145
return 0L ;
3146
3146
}
3147
3147
3148
- long timeUtilVoterChangeExpires = state .maybeExpirePendingOperation (currentTimeMs );
3148
+ long timeUntilVoterChangeExpires = state .maybeExpirePendingOperation (currentTimeMs );
3149
3149
3150
3150
long timeUntilFlush = maybeAppendBatches (
3151
3151
state ,
@@ -3163,7 +3163,7 @@ private long pollLeader(long currentTimeMs) {
3163
3163
timeUntilNextBeginQuorumSend ,
3164
3164
Math .min (
3165
3165
timeUntilCheckQuorumExpires ,
3166
- timeUtilVoterChangeExpires
3166
+ timeUntilVoterChangeExpires
3167
3167
)
3168
3168
)
3169
3169
);
You can’t perform that action at this time.
0 commit comments