[
https://issues.apache.org/jira/browse/KAFKA-19317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shivsundar R reassigned KAFKA-19317:
------------------------------------
Assignee: Shivsundar R
> 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
> Assignee: Shivsundar R
> Priority: Major
>
> 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)
