jsancio commented on a change in pull request #11733:
URL: https://github.com/apache/kafka/pull/11733#discussion_r814424904
##########
File path: core/src/main/scala/kafka/cluster/Partition.scala
##########
@@ -1080,6 +1092,9 @@ class Partition(val topicPartition: TopicPartition,
// decide whether to only fetch from leader
val localLog = localLogWithEpochOrException(currentLeaderEpoch,
fetchOnlyFromLeader)
+ // Check that the partition leader is recovering from an unclean leader
election.
+ validateLeaderRecoveryState()
Review comment:
I didn't implement this now because only the leader can accept PRODUCE
requests and the leader recovers immediately. In this implementation only the
follower needs to wait for the leader to recover so it can accept FETCH
requests.
--
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
