Kirk True created KAFKA-16010:
---------------------------------
Summary: Fix
PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling
Key: KAFKA-16010
URL: https://issues.apache.org/jira/browse/KAFKA-16010
Project: Kafka
Issue Type: Test
Components: clients, consumer, unit tests
Affects Versions: 3.7.0
Reporter: Kirk True
The integration test
{{PlaintextConsumerTest.testMaxPollIntervalMsDelayInRevocation}} is failing
when using the {{AsyncKafkaConsumer}}.
The error is:
{code}
org.opentest4j.AssertionFailedError: Timed out before expected rebalance
completed
at org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:38)
at org.junit.jupiter.api.Assertions.fail(Assertions.java:134)
at
kafka.api.AbstractConsumerTest.awaitRebalance(AbstractConsumerTest.scala:317)
at
kafka.api.PlaintextConsumerTest.testMaxPollIntervalMsDelayInRevocation(PlaintextConsumerTest.scala:235)
{code}
The logs include this line:
{code}
[2023-12-13 15:20:27,824] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] consumer poll timeout has expired. This means the time between
subsequent calls to poll() was longer than the configured max.poll.interval.ms,
which typically implies that the poll loop is spending too much time processing
messages. You can address this either by increasing max.poll.interval.ms or by
reducing the maximum size of batches returned in poll() with max.poll.records.
(org.apache.kafka.clients.consumer.internals.HeartbeatRequestManager:188)
{code}
I don't know if that's related or not.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
