rajinisivaram commented on a change in pull request #9382:
URL: https://github.com/apache/kafka/pull/9382#discussion_r534563838
##########
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##########
@@ -1691,6 +1692,18 @@ class ReplicaManager(val config: KafkaConfig,
partitionsToMakeFollower
}
+ /**
+ * From IBP 2.7 onwards, we send latest fetch epoch in the request and
truncate if a
+ * diverging epoch is returned in the response, avoiding the need for a
separate
+ * OffsetForLeaderEpoch request.
+ */
+ private def initialFetchOffset(log: Log): Long = {
Review comment:
Yes, makes sense, will do that in a follow-up PR.
----------------------------------------------------------------
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:
us...@infra.apache.org
