rajinisivaram commented on a change in pull request #9382:
URL: https://github.com/apache/kafka/pull/9382#discussion_r504803409
##########
File path: core/src/main/scala/kafka/server/DelayedFetch.scala
##########
@@ -77,6 +78,7 @@ class DelayedFetch(delayMs: Long,
* Case E: This broker is the leader, but the requested epoch is now fenced
* Case F: The fetch offset locates not on the last segment of the log
* Case G: The accumulated bytes from all the fetching partitions exceeds
the minimum bytes
+ * Case H: A diverging epoch was found, return response to trigger truncation
Review comment:
PR with the changes in DelayedFetch and FetchSession:
https://github.com/apache/kafka/pull/9434
##########
File path: core/src/main/scala/kafka/server/DelayedFetch.scala
##########
@@ -77,6 +78,7 @@ class DelayedFetch(delayMs: Long,
* Case E: This broker is the leader, but the requested epoch is now fenced
* Case F: The fetch offset locates not on the last segment of the log
* Case G: The accumulated bytes from all the fetching partitions exceeds
the minimum bytes
+ * Case H: A diverging epoch was found, return response to trigger truncation
Review comment:
PR with the changes in DelayedFetch and FetchSession:
https://github.com/apache/kafka/pull/9434
----------------------------------------------------------------
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
