diff --git a/core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala b/core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala index 900971f28ed2d..e8e72400d4823 100644 --- a/core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala +++ b/core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala @@ -166,7 +166,7 @@ class ZkMigrationIntegrationTest { TestUtils.waitUntilTrue( () => zkClient.getControllerId.contains(3000), "Timed out waiting for KRaft controller to take over", - 30_000) + 30000) def inDualWrite(): Boolean = { val migrationState = kraftCluster.controllers().get(3000).migrationSupport.get.migrationDriver.migrationState().get(10, TimeUnit.SECONDS) @@ -292,7 +292,7 @@ class ZkMigrationIntegrationTest { TestUtils.waitUntilTrue( () => zkClient.getControllerId.contains(3000), "Timed out waiting for KRaft controller to take over", - 30_000) + 30000) // Alter the metadata log.info("Updating metadata with AdminClient") @@ -367,7 +367,7 @@ class ZkMigrationIntegrationTest { TestUtils.waitUntilTrue( () => zkClient.getControllerId.contains(3000), "Timed out waiting for KRaft controller to take over", - 30_000) + 30000) // Alter the metadata log.info("Updating metadata with AdminClient") @@ -434,7 +434,7 @@ class ZkMigrationIntegrationTest { TestUtils.waitUntilTrue( () => zkClient.getControllerId.contains(3000), "Timed out waiting for KRaft controller to take over", - 30_000) + 30000) // Alter the metadata log.info("Updating metadata with AdminClient") @@ -496,7 +496,7 @@ class ZkMigrationIntegrationTest { TestUtils.waitUntilTrue( () => zkClient.getControllerId.contains(3000), "Timed out waiting for KRaft controller to take over", - 30_000) + 30000) // Alter the metadata log.info("Create new topic with AdminClient")