diff --git a/kafka-rest/src/test/java/io/confluent/kafkarest/integration/v3/ConsumerLagsResourceIntegrationTest.java b/kafka-rest/src/test/java/io/confluent/kafkarest/integration/v3/ConsumerLagsResourceIntegrationTest.java index 06722f46e1..99ec1d4e7e 100644 --- a/kafka-rest/src/test/java/io/confluent/kafkarest/integration/v3/ConsumerLagsResourceIntegrationTest.java +++ b/kafka-rest/src/test/java/io/confluent/kafkarest/integration/v3/ConsumerLagsResourceIntegrationTest.java @@ -94,12 +94,12 @@ public void listConsumerLags_returnsConsumerLags() { consumer1.subscribe(Collections.singletonList(topic1)); consumer2.subscribe(Collections.singletonList(topic2)); - consumer1.poll(Duration.ofSeconds(5)); - consumer2.poll(Duration.ofSeconds(5)); + consumer1.poll(Duration.ofSeconds(8)); + consumer2.poll(Duration.ofSeconds(8)); // After polling once, only one of the consumers will be member of the group, so we poll again // to force the other consumer to join the group. - consumer1.poll(Duration.ofSeconds(5)); - consumer2.poll(Duration.ofSeconds(5)); + consumer1.poll(Duration.ofSeconds(8)); + consumer2.poll(Duration.ofSeconds(8)); // commit offsets from consuming from subscribed topics consumer1.commitSync(); consumer2.commitSync();