This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 0d95e46f8e4 MINOR: Remove unnecessary min.assignment.interval.ms 
config from test (#22120)
0d95e46f8e4 is described below

commit 0d95e46f8e4cff176a821ac270efe6fd7aec29f0
Author: Sean Quah <[email protected]>
AuthorDate: Thu Apr 23 09:08:03 2026 +0100

    MINOR: Remove unnecessary min.assignment.interval.ms config from test 
(#22120)
    
    Remove the group.consumer.min.assignment.interval.ms config override
    from ConsumerGroupHeartbeatRequestTest's
    testStaticMembersRejoinWithDifferentServerAssignor. The config already
    defaults to 0 and we are very unlikely to ever change it, since we
    always want to allow a 0 value to disable assignment batching.
    
    Reviewers: Chia-Ping Tsai <[email protected]>
---
 .../scala/unit/kafka/server/ConsumerGroupHeartbeatRequestTest.scala    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/core/src/test/scala/unit/kafka/server/ConsumerGroupHeartbeatRequestTest.scala 
b/core/src/test/scala/unit/kafka/server/ConsumerGroupHeartbeatRequestTest.scala
index 6754cb4517a..908bd74494d 100644
--- 
a/core/src/test/scala/unit/kafka/server/ConsumerGroupHeartbeatRequestTest.scala
+++ 
b/core/src/test/scala/unit/kafka/server/ConsumerGroupHeartbeatRequestTest.scala
@@ -1276,8 +1276,7 @@ class ConsumerGroupHeartbeatRequestTest(cluster: 
ClusterInstance) extends GroupC
 
   @ClusterTest(
     serverProperties = Array(
-      new ClusterConfigProperty(key = 
GroupCoordinatorConfig.CONSUMER_GROUP_ASSIGNMENT_INTERVAL_MS_CONFIG, value = 
"0"),
-      new ClusterConfigProperty(key = 
GroupCoordinatorConfig.CONSUMER_GROUP_MIN_ASSIGNMENT_INTERVAL_MS_CONFIG, value 
= "0")
+      new ClusterConfigProperty(key = 
GroupCoordinatorConfig.CONSUMER_GROUP_ASSIGNMENT_INTERVAL_MS_CONFIG, value = 
"0")
     )
   )
   def testStaticMembersRejoinWithDifferentServerAssignor(): Unit = {

Reply via email to