dengziming commented on a change in pull request #11634:
URL: https://github.com/apache/kafka/pull/11634#discussion_r780047401
##########
File path:
core/src/test/scala/unit/kafka/admin/TopicCommandIntegrationTest.scala
##########
@@ -443,25 +486,30 @@ class TopicCommandIntegrationTest extends
KafkaServerTestHarness with Logging wi
val deleteOffsetTopicOpts = new TopicCommandOptions(
Array("--topic", Topic.GROUP_METADATA_TOPIC_NAME))
val deleteOffsetTopicPath =
DeleteTopicsTopicZNode.path(Topic.GROUP_METADATA_TOPIC_NAME)
- assertFalse(zkClient.pathExists(deleteOffsetTopicPath), "Delete path for
topic shouldn't exist before deletion.")
+ if (!isKRaftTest()) {
+ assertFalse(zkClient.pathExists(deleteOffsetTopicPath), "Delete path for
topic shouldn't exist before deletion.")
+ }
topicService.deleteTopic(deleteOffsetTopicOpts)
- TestUtils.verifyTopicDeletion(zkClient, Topic.GROUP_METADATA_TOPIC_NAME,
1, servers)
+ TestUtils.waitForAllPartitionsMetadata(brokers, testTopicName, 0)
Review comment:
Should we wait for `Topic.GROUP_METADATA_TOPIC_NAME` rather than
`testTopicName` ?
--
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
