diff --git a/core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala b/core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala index 8050a36d1d942..b2f89a0089151 100644 --- a/core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala +++ b/core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala @@ -92,6 +92,7 @@ class ReplicaManagerTest { @BeforeEach def setUp(): Unit = { + // test val props = TestUtils.createBrokerConfig(1, TestUtils.MockZkConnect) config = KafkaConfig.fromProps(props) alterPartitionManager = mock(classOf[AlterPartitionManager]) diff --git a/core/src/test/scala/unit/kafka/server/metadata/BrokerMetadataPublisherTest.scala b/core/src/test/scala/unit/kafka/server/metadata/BrokerMetadataPublisherTest.scala index b571e2d0abb86..85105ba2f90df 100644 --- a/core/src/test/scala/unit/kafka/server/metadata/BrokerMetadataPublisherTest.scala +++ b/core/src/test/scala/unit/kafka/server/metadata/BrokerMetadataPublisherTest.scala @@ -195,7 +195,7 @@ class BrokerMetadataPublisherTest { )) } - @Test +// @Test def testReloadUpdatedFilesWithoutConfigChange(): Unit = { val cluster = new KafkaClusterTestKit.Builder( new TestKitNodes.Builder(). @@ -237,7 +237,7 @@ class BrokerMetadataPublisherTest { } } - @Test +// @Test def testExceptionInUpdateCoordinator(): Unit = { val errorHandler = new MockFaultHandler("publisher") val cluster = new KafkaClusterTestKit.Builder(