You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ca...@apache.org on 2023/10/20 08:40:26 UTC
[kafka] branch 3.5 updated: Fix a Scala 2.12 compile issue (#14126)
This is an automated email from the ASF dual-hosted git repository.
cadonna pushed a commit to branch 3.5
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.5 by this push:
new 319dc61de79 Fix a Scala 2.12 compile issue (#14126)
319dc61de79 is described below
commit 319dc61de79927288c9d13cede8456c14e5702a0
Author: David Arthur <mu...@gmail.com>
AuthorDate: Mon Jul 31 09:21:22 2023 -0400
Fix a Scala 2.12 compile issue (#14126)
Reviewers: Luke Chen <sh...@gmail.com>, Qichao Chu
---
.../integration/kafka/zk/ZkMigrationIntegrationTest.scala | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala b/core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala
index 900971f28ed..e8e72400d48 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")