remove config with reduce test time less test

apache · Aug 11, 2024 · 9aedd6a · 9aedd6a
1 parent dc4a5e7
commit 9aedd6a
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 8 deletions.
diff --git a/core/src/test/scala/integration/kafka/server/KafkaServerKRaftRegistrationTest.scala b/core/src/test/scala/integration/kafka/server/KafkaServerKRaftRegistrationTest.scala
@@ -49,8 +49,7 @@ class KafkaServerKRaftRegistrationTest {
     new ClusterConfigProperty(key = "inter.broker.listener.name", value = "EXTERNAL"),
     new ClusterConfigProperty(key = "listeners", value = "PLAINTEXT://localhost:0,EXTERNAL://localhost:0"),
     new ClusterConfigProperty(key = "advertised.listeners", value = "PLAINTEXT://localhost:0,EXTERNAL://localhost:0"),
-    new ClusterConfigProperty(key = "listener.security.protocol.map", value = "EXTERNAL:PLAINTEXT,PLAINTEXT:PLAINTEXT"),
-    new ClusterConfigProperty(key = "group.initial.rebalance.delay.ms", value = "1"),
+    new ClusterConfigProperty(key = "listener.security.protocol.map", value = "EXTERNAL:PLAINTEXT,PLAINTEXT:PLAINTEXT")
   ))
   def testRegisterZkBrokerInKraft(zkCluster: ClusterInstance): Unit = {
     val clusterId = zkCluster.clusterId()

diff --git a/core/src/test/scala/unit/kafka/server/ConsumerProtocolMigrationTest.scala b/core/src/test/scala/unit/kafka/server/ConsumerProtocolMigrationTest.scala
@@ -36,8 +36,7 @@ class ConsumerProtocolMigrationTest(cluster: ClusterInstance) extends GroupCoord
     serverProperties = Array(
       new ClusterConfigProperty(key = "group.coordinator.rebalance.protocols", value = "classic,consumer"),
       new ClusterConfigProperty(key = "offsets.topic.num.partitions", value = "1"),
-      new ClusterConfigProperty(key = "offsets.topic.replication.factor", value = "1"),
-      new ClusterConfigProperty(key = "group.initial.rebalance.delay.ms", value = "1"),
+      new ClusterConfigProperty(key = "offsets.topic.replication.factor", value = "1")
     )
   )
   def testUpgradeFromEmptyClassicToConsumerGroup(): Unit = {

diff --git a/core/src/test/scala/unit/kafka/server/OffsetFetchRequestTest.scala b/core/src/test/scala/unit/kafka/server/OffsetFetchRequestTest.scala
@@ -40,8 +40,7 @@ class OffsetFetchRequestTest(cluster: ClusterInstance) extends GroupCoordinatorB
       new ClusterConfigProperty(key = "group.consumer.max.session.timeout.ms", value = "600000"),
       new ClusterConfigProperty(key = "group.consumer.session.timeout.ms", value = "600000"),
       new ClusterConfigProperty(key = "offsets.topic.num.partitions", value = "1"),
-      new ClusterConfigProperty(key = "offsets.topic.replication.factor", value = "1"),
-      new ClusterConfigProperty(key = "group.initial.rebalance.delay.ms", value = "1"),
+      new ClusterConfigProperty(key = "offsets.topic.replication.factor", value = "1")
     )
   )
   def testSingleGroupOffsetFetchWithNewConsumerGroupProtocolAndNewGroupCoordinator(): Unit = {
@@ -54,8 +53,7 @@ class OffsetFetchRequestTest(cluster: ClusterInstance) extends GroupCoordinatorB
       new ClusterConfigProperty(key = "group.consumer.max.session.timeout.ms", value = "600000"),
       new ClusterConfigProperty(key = "group.consumer.session.timeout.ms", value = "600000"),
       new ClusterConfigProperty(key = "offsets.topic.num.partitions", value = "1"),
-      new ClusterConfigProperty(key = "offsets.topic.replication.factor", value = "1"),
-      new ClusterConfigProperty(key = "group.initial.rebalance.delay.ms", value = "1"),
+      new ClusterConfigProperty(key = "offsets.topic.replication.factor", value = "1")
     )
   )
   def testSingleGroupOffsetFetchWithOldConsumerGroupProtocolAndNewGroupCoordinator(): Unit = {