You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Shivsundar R (Jira)" <ji...@apache.org> on 2025/06/02 05:12:00 UTC

[jira] [Commented] (KAFKA-19317) Fix flaky test : ShareConsumerTest.testAlterReadUncommittedToReadCommittedIsolationLevel()

    [ https://issues.apache.org/jira/browse/KAFKA-19317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955561#comment-17955561 ] 

Shivsundar R commented on KAFKA-19317:
--------------------------------------

the test has not been flaky for more than a week on trunk since [https://github.com/apache/kafka/pull/19824] was merged.
Develocity link : https://develocity.apache.org/scans/tests?search.names=CI%20workflow%2CGit%20repository&search.relativeStartTime=P28D&search.rootProjectNames=kafka&search.tags=github%2Ctrunk&search.tasks=test&search.timeZoneId=Asia%2FCalcutta&search.values=CI%2Chttps:%2F%2Fgithub.com%2Fapache%2Fkafka&tests.container=org.apache.kafka.clients.consumer.ShareConsumerTest&tests.test=testAlterReadUncommittedToReadCommittedIsolationLevel()%5B1%5D

> 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)