[kafka] branch 3.1 updated: KAFKA-13583; Fix FetchRequestBetweenDifferentIbpTest flaky tests (#11699)

[dajac]

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

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


The following commit(s) were added to refs/heads/3.1 by this push:
     new 9a7e975  KAFKA-13583; Fix FetchRequestBetweenDifferentIbpTest flaky 
tests (#11699)
9a7e975 is described below

commit 9a7e975f661a80d17f6fb0693ae5387081606873
Author: Kvicii <42023367+kvi...@users.noreply.github.com>
AuthorDate: Thu Feb 3 17:59:12 2022 +0800

    KAFKA-13583; Fix FetchRequestBetweenDifferentIbpTest flaky tests (#11699)
    
    Co-authored-by: Kvicii <karonaz...@gmail.com>
    Reviewers: David Jacot <dja...@confluent.io>
---
 .../kafka/server/FetchRequestBetweenDifferentIbpTest.scala          | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/core/src/test/scala/integration/kafka/server/FetchRequestBetweenDifferentIbpTest.scala
 
b/core/src/test/scala/integration/kafka/server/FetchRequestBetweenDifferentIbpTest.scala
index 37ac4a2..d10bafd 100644
--- 
a/core/src/test/scala/integration/kafka/server/FetchRequestBetweenDifferentIbpTest.scala
+++ 
b/core/src/test/scala/integration/kafka/server/FetchRequestBetweenDifferentIbpTest.scala
@@ -73,7 +73,7 @@ class FetchRequestBetweenDifferentIbpTest extends 
BaseRequestTest {
     producer.send(record2)
 
     consumer.assign(asList(new TopicPartition(topic, 0), new 
TopicPartition(topic, 1)))
-    val count = consumer.poll(Duration.ofMillis(1500)).count() + 
consumer.poll(Duration.ofMillis(1500)).count()
+    val count = consumer.poll(Duration.ofMillis(5000)).count() + 
consumer.poll(Duration.ofMillis(5000)).count()
     assertEquals(2, count)
   }
 
@@ -109,7 +109,7 @@ class FetchRequestBetweenDifferentIbpTest extends 
BaseRequestTest {
 
     consumer.assign(asList(new TopicPartition(topic, 0), new 
TopicPartition(topic, 1)))
 
-    val count = consumer.poll(Duration.ofMillis(1500)).count() + 
consumer.poll(Duration.ofMillis(1500)).count()
+    val count = consumer.poll(Duration.ofMillis(5000)).count() + 
consumer.poll(Duration.ofMillis(5000)).count()
     assertEquals(2, count)
 
     // Make controller version2
@@ -128,7 +128,7 @@ class FetchRequestBetweenDifferentIbpTest extends 
BaseRequestTest {
     // Assign this new topic in addition to the old topics.
     consumer.assign(asList(new TopicPartition(topic, 0), new 
TopicPartition(topic, 1), new TopicPartition(topic2, 0)))
 
-    val count2 = consumer.poll(Duration.ofMillis(1500)).count() + 
consumer.poll(Duration.ofMillis(1500)).count()
+    val count2 = consumer.poll(Duration.ofMillis(5000)).count() + 
consumer.poll(Duration.ofMillis(5000)).count()
     assertEquals(2, count2)
   }