ahuang98 commented on code in PR #14428: URL: https://github.com/apache/kafka/pull/14428#discussion_r1350814062
########## raft/src/main/java/org/apache/kafka/raft/LeaderState.java: ########## @@ -79,6 +86,38 @@ protected LeaderState( this.grantingVoters = Collections.unmodifiableSet(new HashSet<>(grantingVoters)); this.log = logContext.logger(LeaderState.class); this.accumulator = Objects.requireNonNull(accumulator, "accumulator must be non-null"); + this.fetchTimeoutMs = fetchTimeoutMs; + this.fetchTimer = time.timer(fetchTimeoutMs); + } + + // Check if the fetchTimer is expired because we didn't receive fetch/fetchSnapshot request from the majority of Review Comment: nit: ```suggestion // Check if the fetchTimer is expired because we didn't receive a valid fetch/fetchSnapshot request from the majority of ``` same for the next method's description -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org