jsancio commented on a change in pull request #9553:
URL: https://github.com/apache/kafka/pull/9553#discussion_r547481788
##########
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##########
@@ -1629,16 +1872,29 @@ private long pollFollowerAsVoter(FollowerState state,
long currentTimeMs) throws
transitionToCandidate(currentTimeMs);
return 0L;
} else {
- long backoffMs = maybeSendRequest(
- currentTimeMs,
- state.leaderId(),
- this::buildFetchRequest
- );
+ long backoffMs;
+ if (state.fetchingSnapshot().isPresent()) {
Review comment:
I cleaned this up by moving it to a method we can reuse. Let me know if
that addresses your concern.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
