root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

KAFKA-13583; Fix FetchRequestBetweenDifferentIbpTest flaky tests (#11699) 

Co-authored-by: Kvicii <Karonazaba@gmail.com>
Reviewers: David Jacot <djacot@confluent.io>
This commit is contained in:
Kvicii 2022-02-03 17:59:12 +08:00 committed by GitHub
parent 3781117653
commit 21c3009ac1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
core/src/test/scala/integration/kafka/server/FetchRequestBetweenDifferentIbpTest.scala
View File

@ -73,7 +73,7 @@ class FetchRequestBetweenDifferentIbpTest extends BaseRequestTest {
producer.send(record2) producer.send(record2)
consumer.assign(asList(new TopicPartition(topic, 0), new TopicPartition(topic, 1))) 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) assertEquals(2, count)
} }
@ -109,7 +109,7 @@ class FetchRequestBetweenDifferentIbpTest extends BaseRequestTest {
consumer.assign(asList(new TopicPartition(topic, 0), new TopicPartition(topic, 1))) 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) assertEquals(2, count)
// Make controller version2 // Make controller version2
@ -128,7 +128,7 @@ class FetchRequestBetweenDifferentIbpTest extends BaseRequestTest {
// Assign this new topic in addition to the old topics. // 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))) 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) assertEquals(2, count2)
} }