You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ch...@apache.org on 2026/04/23 08:08:09 UTC
(kafka) branch trunk updated: MINOR: Remove unnecessary min.assignment.interval.ms config from test (#22120)
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 <sq...@confluent.io>
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 <ch...@gmail.com>
---
.../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 = {