ijuma commented on a change in pull request #9855: URL: https://github.com/apache/kafka/pull/9855#discussion_r554628355
########## File path: core/src/test/scala/integration/kafka/admin/BrokerApiVersionsCommandTest.scala ########## @@ -19,24 +19,25 @@ package kafka.admin import java.io.{ByteArrayOutputStream, PrintStream} import java.nio.charset.StandardCharsets - import scala.collection.Seq - import kafka.integration.KafkaServerTestHarness import kafka.server.KafkaConfig import kafka.utils.TestUtils import org.apache.kafka.clients.NodeApiVersions import org.apache.kafka.common.protocol.ApiKeys -import org.junit.Assert.{assertEquals, assertFalse, assertNotNull, assertTrue} -import org.junit.Test +import org.junit.jupiter.api.Assertions.{assertEquals, assertFalse, assertNotNull, assertTrue} +import org.junit.jupiter.api.Test +import org.junit.jupiter.api.Timeout +import java.util.concurrent.TimeUnit import scala.jdk.CollectionConverters._ class BrokerApiVersionsCommandTest extends KafkaServerTestHarness { def generateConfigs: Seq[KafkaConfig] = TestUtils.createBrokerConfigs(1, zkConnect).map(KafkaConfig.fromProps) - @Test(timeout=120000) + @Timeout(value = 120000, unit = TimeUnit.MILLISECONDS) Review comment: A more concise approoach is `@Timeout(120)`. ########## File path: core/src/test/scala/integration/kafka/admin/BrokerApiVersionsCommandTest.scala ########## @@ -19,24 +19,25 @@ package kafka.admin import java.io.{ByteArrayOutputStream, PrintStream} import java.nio.charset.StandardCharsets - import scala.collection.Seq - import kafka.integration.KafkaServerTestHarness import kafka.server.KafkaConfig import kafka.utils.TestUtils import org.apache.kafka.clients.NodeApiVersions import org.apache.kafka.common.protocol.ApiKeys -import org.junit.Assert.{assertEquals, assertFalse, assertNotNull, assertTrue} -import org.junit.Test +import org.junit.jupiter.api.Assertions.{assertEquals, assertFalse, assertNotNull, assertTrue} +import org.junit.jupiter.api.Test +import org.junit.jupiter.api.Timeout +import java.util.concurrent.TimeUnit import scala.jdk.CollectionConverters._ class BrokerApiVersionsCommandTest extends KafkaServerTestHarness { def generateConfigs: Seq[KafkaConfig] = TestUtils.createBrokerConfigs(1, zkConnect).map(KafkaConfig.fromProps) - @Test(timeout=120000) + @Timeout(value = 120000, unit = TimeUnit.MILLISECONDS) Review comment: A more concise approach is `@Timeout(120)`. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org