(kafka) branch trunk updated: KAFKA-17904: Flaky testMultiConsumerSessionTimeoutOnClose (#17789)

[lianetm]

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

lianetm 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 283d56cf569 KAFKA-17904: Flaky testMultiConsumerSessionTimeoutOnClose 
(#17789)
283d56cf569 is described below

commit 283d56cf569d0071bac146a06dc81ca33077dab4
Author: xijiu <422766...@qq.com>
AuthorDate: Sat Nov 16 02:39:16 2024 +0800

    KAFKA-17904: Flaky testMultiConsumerSessionTimeoutOnClose (#17789)
    
    Reviewers: Lianet Magrans <lmagr...@confluent.io>
---
 .../scala/integration/kafka/api/PlaintextConsumerPollTest.scala   | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git 
a/core/src/test/scala/integration/kafka/api/PlaintextConsumerPollTest.scala 
b/core/src/test/scala/integration/kafka/api/PlaintextConsumerPollTest.scala
index 9e6460df050..9280b6af475 100644
--- a/core/src/test/scala/integration/kafka/api/PlaintextConsumerPollTest.scala
+++ b/core/src/test/scala/integration/kafka/api/PlaintextConsumerPollTest.scala
@@ -16,6 +16,7 @@ import kafka.utils.{TestInfoUtils, TestUtils}
 import org.apache.kafka.clients.consumer._
 import org.apache.kafka.common.{MetricName, TopicPartition}
 import org.apache.kafka.common.utils.Utils
+import org.apache.kafka.coordinator.group.GroupCoordinatorConfig
 import org.junit.jupiter.api.Assertions._
 import org.junit.jupiter.api.Timeout
 import org.junit.jupiter.params.ParameterizedTest
@@ -23,6 +24,7 @@ import org.junit.jupiter.params.provider.MethodSource
 
 import java.time.Duration
 import java.util
+import java.util.Properties
 import scala.collection.mutable
 import scala.jdk.CollectionConverters._
 
@@ -32,6 +34,12 @@ import scala.jdk.CollectionConverters._
 @Timeout(600)
 class PlaintextConsumerPollTest extends AbstractConsumerTest {
 
+  override protected def brokerPropertyOverrides(properties: Properties): Unit 
= {
+    super.brokerPropertyOverrides(properties)
+    
properties.setProperty(GroupCoordinatorConfig.CONSUMER_GROUP_HEARTBEAT_INTERVAL_MS_CONFIG,
 500.toString)
+    
properties.setProperty(GroupCoordinatorConfig.CONSUMER_GROUP_MIN_HEARTBEAT_INTERVAL_MS_CONFIG,
 500.toString)
+  }
+
   @ParameterizedTest(name = 
TestInfoUtils.TestWithParameterizedQuorumAndGroupProtocolNames)
   @MethodSource(Array("getTestQuorumAndGroupProtocolParametersAll"))
   def testMaxPollRecords(quorum: String, groupProtocol: String): Unit = {