jolshan commented on a change in pull request #11331:
URL: https://github.com/apache/kafka/pull/11331#discussion_r746783340
##########
File path: core/src/test/scala/unit/kafka/server/FetchSessionTest.scala
##########
@@ -967,6 +967,113 @@ class FetchSessionTest {
.setErrorCode(errorCode)
}
+ @Test
Review comment:
There are two places it may be resolved -- either in the update method
if the partition with the new ID is sent in the request or in the
assertPartitionsOrder. I was also trying to ensure the correct error messages
are returned in the response specifically via `updateAndGenerateResponseData`,
but maybe we don't care about this 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
