satishd commented on a change in pull request #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r773121075
##########
File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala
##########
@@ -396,7 +399,12 @@ abstract class AbstractFetcherThread(name: String,
case Errors.OFFSET_OUT_OF_RANGE =>
if (handleOutOfRangeError(topicPartition, currentFetchState,
fetchPartitionData.currentLeaderEpoch))
partitionsWithError += topicPartition
-
+ case Errors.OFFSET_MOVED_TO_TIERED_STORAGE =>
+ // No need to retry this as it indicates that the requested
offset is moved to tiered storage.
+ // Check whether topicId is available here.
Review comment:
Updated the comment, we do not really need to have a check here. Let me
know if I am missing anything here.
--
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
