fix config from 1ms to 1000ms

apache · Aug 20, 2024 · d3bb650 · d3bb650
1 parent 44e7e18
commit d3bb650
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/core/src/test/scala/unit/kafka/server/JoinGroupRequestTest.scala b/core/src/test/scala/unit/kafka/server/JoinGroupRequestTest.scala
@@ -43,7 +43,7 @@ class JoinGroupRequestTest(cluster: ClusterInstance) extends GroupCoordinatorBas
     new ClusterConfigProperty(key = "group.coordinator.new.enable", value = "true"),
     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 = "group.initial.rebalance.delay.ms", value = "1000"),
   ))
   def testJoinGroupWithOldConsumerGroupProtocolAndNewGroupCoordinator(): Unit = {
     testJoinGroup()
@@ -53,7 +53,7 @@ class JoinGroupRequestTest(cluster: ClusterInstance) extends GroupCoordinatorBas
     new ClusterConfigProperty(key = "group.coordinator.new.enable", value = "false"),
     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 = "group.initial.rebalance.delay.ms", value = "1000"),
   ))
   def testJoinGroupWithOldConsumerGroupProtocolAndOldGroupCoordinator(): Unit = {
     testJoinGroup()

diff --git a/core/src/test/scala/unit/kafka/server/ListGroupsRequestTest.scala b/core/src/test/scala/unit/kafka/server/ListGroupsRequestTest.scala
@@ -39,7 +39,7 @@ class ListGroupsRequestTest(cluster: ClusterInstance) extends GroupCoordinatorBa
       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 = "group.initial.rebalance.delay.ms", value = "1000"),
     )
   )
   def testListGroupsWithNewConsumerGroupProtocolAndNewGroupCoordinator(): Unit = {
@@ -50,7 +50,7 @@ class ListGroupsRequestTest(cluster: ClusterInstance) extends GroupCoordinatorBa
     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 = "group.initial.rebalance.delay.ms", value = "1000"),
   ))
   def testListGroupsWithOldConsumerGroupProtocolAndNewGroupCoordinator(): Unit = {
     testListGroups(false)
@@ -60,7 +60,7 @@ class ListGroupsRequestTest(cluster: ClusterInstance) extends GroupCoordinatorBa
     new ClusterConfigProperty(key = "group.coordinator.rebalance.protocols", value = "classic"),
     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 = "group.initial.rebalance.delay.ms", value = "1000"),
   ))
   def testListGroupsWithOldConsumerGroupProtocolAndOldGroupCoordinator(): Unit = {
     testListGroups(false)

diff --git a/core/src/test/scala/unit/kafka/server/SyncGroupRequestTest.scala b/core/src/test/scala/unit/kafka/server/SyncGroupRequestTest.scala
@@ -41,7 +41,7 @@ class SyncGroupRequestTest(cluster: ClusterInstance) extends GroupCoordinatorBas
     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 = "group.initial.rebalance.delay.ms", value = "1000"),
   ))
   def testSyncGroupWithOldConsumerGroupProtocolAndNewGroupCoordinator(): Unit = {
     testSyncGroup()
@@ -51,7 +51,7 @@ class SyncGroupRequestTest(cluster: ClusterInstance) extends GroupCoordinatorBas
     new ClusterConfigProperty(key = "group.coordinator.rebalance.protocols", value = "classic"),
     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 = "group.initial.rebalance.delay.ms", value = "1000"),
   ))
   def testSyncGroupWithOldConsumerGroupProtocolAndOldGroupCoordinator(): Unit = {
     testSyncGroup()