lytt925 opened a new pull request, #23715: URL: https://github.com/apache/kafka/pull/23715
Follow-up to [#23699](https://github.com/apache/kafka/pull/23699#discussion_r4183223408) to apply the same changes to ClusterInstance#deleteTopic. ClusterInstance#deleteTopic did not wait for the DeleteTopics result. If the deletion failed, the error was either ignored (e.g. the topic did not exist) or hidden by the waitTopicDeletion timeout. It now calls get() so that the real error can be propagated. As with createTopic, a RuntimeException cause is rethrown as is, and callers no longer need to handle ExecutionException and InterruptedException. - Also do a cleanup to use ClusterInstance#deleteTopic where a test deletes a topic and then immediately waits for the deletion. - Renamed ClusterTestExtensionsTest#testVerifyTopicDeletion to testDeleteTopic and also verifies that deleting a non-existent topic throws UnknownTopicOrPartitionException. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
