dengziming commented on code in PR #12329:
URL: https://github.com/apache/kafka/pull/12329#discussion_r904742833
##########
core/src/test/scala/unit/kafka/server/AlterPartitionManagerTest.scala:
##########
@@ -178,6 +178,46 @@ class AlterPartitionManagerTest {
assertEquals(request.data().topics().get(0).partitions().size(), 10)
}
+ @Test
+ def testRetryOnPartitionLevelError(): Unit = {
+ // prepare a partition level retriable error response
+ val alterPartitionRespWithPartitionError = partitionResponse(tp0,
Errors.UNKNOWN_SERVER_ERROR)
+ val errorResponse =
makeClientResponse(alterPartitionRespWithPartitionError,
ApiKeys.ALTER_PARTITION.latestVersion)
+
+ val leaderAndIsr = new LeaderAndIsr(1, 1, List(1,2,3),
LeaderRecoveryState.RECOVERED, 10)
+ val callbackCapture: ArgumentCaptor[ControllerRequestCompletionHandler] =
ArgumentCaptor.forClass(classOf[ControllerRequestCompletionHandler])
Review Comment:
nitpick: It's unnecessary to specify the type of local variable.
--
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
