dajac commented on a change in pull request #11331: URL: https://github.com/apache/kafka/pull/11331#discussion_r743044369
########## File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala ########## @@ -374,7 +374,7 @@ abstract class AbstractFetcherThread(name: String, } } } catch { - case ime@( _: CorruptRecordException | _: InvalidRecordException) => + case ime@(_: CorruptRecordException | _: InvalidRecordException) => Review comment: I think that would for instance happen when the controller fails over to an older IBP during an upgrade. This should remove the topic ids which means that v12 will be used for the next fetch request and trigger a FETCH_SESSION_TOPIC_ID_ERROR. In this particular case, re-trying directly would be the optimal way to proceed for a follower. I wonder if they are other cases to consider here. For the consumer, it is definitely different. -- 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