Fix a Scala 2.12 compile issue (#14126)

Reviewers: Luke Chen <showuon@gmail.com>, Qichao Chu
apache · Jul 31, 2023 · 938fee2 · 938fee2
1 parent 3ba718e
commit 938fee2
Showing 1 changed file with 5 additions and 5 deletions.
diff --git 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")