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 51fa1601c17 KAFKA-20333: Fix flaky consumer test (#21815)
51fa1601c17 is described below
commit 51fa1601c173c956eb6f3cc001288af540298fdf
Author: Lianet Magrans <[email protected]>
AuthorDate: Wed Mar 18 19:45:04 2026 -0400
KAFKA-20333: Fix flaky consumer test (#21815)
Flaky on trunk, log showed poll timer expired, so increasing it to 1000
(aligned with other tests in the file) to ensure that it's still low
enough so that when a consumer poll is stopped it eventually hits the
poll timer and leaves, but not too low that the other stable consumers
may get an expired poll-timer across rebalances.
Reviewers: Chia-Ping Tsai <[email protected]>
---
.../org/apache/kafka/clients/consumer/PlaintextConsumerPollTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerPollTest.java
b/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerPollTest.java
index ef5df01cf51..ab801a981c5 100644
---
a/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerPollTest.java
+++
b/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerPollTest.java
@@ -418,7 +418,7 @@ public class PlaintextConsumerPollTest {
Map<String, Object> config = Map.of(
GROUP_PROTOCOL_CONFIG,
groupProtocol.name().toLowerCase(Locale.ROOT),
GROUP_ID_CONFIG, "test-group",
- MAX_POLL_INTERVAL_MS_CONFIG, 100
+ MAX_POLL_INTERVAL_MS_CONFIG, 1000
);
// use consumers defined in this class plus one additional consumer
// Use topic defined in this class + one additional topic
