akhileshchg commented on code in PR #12106:
URL: https://github.com/apache/kafka/pull/12106#discussion_r863474931
##########
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##########
@@ -499,23 +504,28 @@ class PlaintextAdminIntegrationTest extends
BaseAdminIntegrationTest {
e = assertThrows(classOf[ExecutionException], () =>
alterResult.values.get(topic2).get,
() => s"$desc: Expect InvalidPartitionsException when requesting a
noop")
assertTrue(e.getCause.isInstanceOf[InvalidPartitionsException], desc)
- assertEquals("Topic already has 3 partitions.", e.getCause.getMessage,
desc)
+ exceptionMsgStr = if (TestInfoUtils.isKRaft(testInfo)) {
+ "Topic already has 3 partition(s)."
+ } else {
+ "Topic already has 3 partitions."
Review Comment:
There are too many error messages in the `ReplicationControl` layer, and I'm
not sure how many other layers need to be changed. I think this can be a
different PR to keep the messages intact if required.
--
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
