Shivsundar R created KAFKA-19317:
------------------------------------
Summary: Fix flaky test :
ShareConsumerTest.testAlterReadUncommittedToReadCommittedIsolationLevel()
Key: KAFKA-19317
URL: https://issues.apache.org/jira/browse/KAFKA-19317
Project: Kafka
Issue Type: Sub-task
Reporter: Shivsundar R
The test has been flaky recently.
{code:java}
2025-05-17T16:09:18.3295491Z
org.apache.kafka.clients.consumer.ShareConsumerTest.testAlterReadUncommittedToReadCommittedIsolationLevel()[1]
failed, log available in
/home/runner/work/kafka/kafka/clients/clients-integration-tests/build/reports/testOutput/org.apache.kafka.clients.consumer.ShareConsumerTest.testAlterReadUncommittedToReadCommittedIsolationLevel()[1].test.stdout
2025-05-17T16:09:18.3298136Z 2025-05-17T16:09:18.3301226Z Gradle Test Run
:clients:clients-integration-tests:test > Gradle Test Executor 72 >
ShareConsumerTest > testAlterReadUncommittedToReadCommittedIsolationLevel() >
testAlterReadUncommittedToReadCommittedIsolationLevel [1] Type=Raft-Isolated,
MetadataVersion=4.2-IV1,BrokerSecurityProtocol=PLAINTEXT,BrokerListenerName=ListenerName(EXTERNAL),ControllerSecurityProtocol=PLAINTEXT,ControllerListenerName=ListenerName(CONTROLLER)
FAILED 2025-05-17T16:09:18.3304801Z java.lang.AssertionError: Assertion failed
with an exception after 15000 ms 2025-05-17T16:09:18.3305978Z at
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:493)
2025-05-17T16:09:18.3306932Z at
org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:432)
2025-05-17T16:09:18.3307957Z at
org.apache.kafka.clients.consumer.ShareConsumerTest.waitedPoll(ShareConsumerTest.java:2990)
2025-05-17T16:09:18.3309682Z at
org.apache.kafka.clients.consumer.ShareConsumerTest.waitedPoll(ShareConsumerTest.java:2977)
2025-05-17T16:09:18.3311489Z at
org.apache.kafka.clients.consumer.ShareConsumerTest.testAlterReadUncommittedToReadCommittedIsolationLevel(ShareConsumerTest.java:2322)
2025-05-17T16:09:18.3312926Z 2025-05-17T16:09:18.3313059Z Caused by:
2025-05-17T16:09:18.3313651Z java.lang.IllegalStateException: All records must
be acknowledged in explicit acknowledgement mode. 2025-05-17T16:09:18.3314782Z
at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.collect(ShareConsumerImpl.java:667)
2025-05-17T16:09:18.3315980Z at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.pollForFetches(ShareConsumerImpl.java:616)
2025-05-17T16:09:18.3317151Z at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.poll(ShareConsumerImpl.java:592)
2025-05-17T16:09:18.3318188Z at
org.apache.kafka.clients.consumer.KafkaShareConsumer.poll(KafkaShareConsumer.java:474)
2025-05-17T16:09:18.3319760Z at
org.apache.kafka.clients.consumer.ShareConsumerTest.lambda$waitedPoll$139(ShareConsumerTest.java:2991)
2025-05-17T16:09:18.3320896Z at
org.apache.kafka.test.TestUtils.lambda$waitForCondition$4(TestUtils.java:435)
2025-05-17T16:09:18.3322031Z at
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:483)
2025-05-17T16:09:18.3322767Z ... 4 more{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
