[kafka] branch trunk updated: KAFKA-10404; Use higher poll timeout to avoid rebalance in testCoordinatorFailover (#9183)

[rsivaram]

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

rsivaram 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 d8d9d1a  KAFKA-10404; Use higher poll timeout to avoid rebalance in 
testCoordinatorFailover (#9183)
d8d9d1a is described below

commit d8d9d1a559c6564a7690ddaeebaeb53a52ceec4a
Author: Rajini Sivaram <rajinisiva...@googlemail.com>
AuthorDate: Sun Aug 16 14:43:21 2020 +0100

    KAFKA-10404; Use higher poll timeout to avoid rebalance in 
testCoordinatorFailover (#9183)
    
    Reviewers: Manikumar Reddy <manikumar.re...@gmail.com>
---
 core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala 
b/core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala
index e458b59..c66f3d1 100644
--- a/core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala
+++ b/core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala
@@ -52,7 +52,9 @@ abstract class BaseConsumerTest extends AbstractConsumerTest {
   def testCoordinatorFailover(): Unit = {
     val listener = new TestConsumerReassignmentListener()
     this.consumerConfig.setProperty(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, 
"5001")
-    
this.consumerConfig.setProperty(ConsumerConfig.HEARTBEAT_INTERVAL_MS_CONFIG, 
"2000")
+    
this.consumerConfig.setProperty(ConsumerConfig.HEARTBEAT_INTERVAL_MS_CONFIG, 
"1000")
+    // Use higher poll timeout to avoid consumer leaving the group due to 
timeout
+    
this.consumerConfig.setProperty(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, 
"15000")
     val consumer = createConsumer()
 
     consumer.subscribe(List(topic).asJava, listener)