[KAFKA-15416] Flaky test TopicAdminTest::retryEndOffsetsShouldRetryWhenTopicNotFound

• Type: Test
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 3.6.0
• Component/s: connect
• Assignee: Chris Egerton
• Reporter: Chris Egerton
• Created: 29/Aug/23 15:42
• Updated: 11/Sep/23 14:15
• Resolved: 07/Sep/23 23:25

Description

This test fails frequently when I run unit tests locally, but I've never seen it fail during a CI build.

Failure message:

    org.apache.kafka.connect.errors.ConnectException: Failed to list offsets for topic partitions.

        at app//org.apache.kafka.connect.util.TopicAdmin.retryEndOffsets(TopicAdmin.java:777)

        at app//org.apache.kafka.connect.util.TopicAdminTest.retryEndOffsetsShouldRetryWhenTopicNotFound(TopicAdminTest.java:570)

 

        Caused by:

        org.apache.kafka.connect.errors.ConnectException: Fail to list offsets for topic partitions after 1 attempts.  Reason: Timed out while waiting to get end offsets for topic 'myTopic' on brokers at {retry.backoff.ms=0}

            at app//org.apache.kafka.connect.util.RetryUtil.retryUntilTimeout(RetryUtil.java:106)

            at app//org.apache.kafka.connect.util.RetryUtil.retryUntilTimeout(RetryUtil.java:56)

            at app//org.apache.kafka.connect.util.TopicAdmin.retryEndOffsets(TopicAdmin.java:768)

            ... 1 more

 

            Caused by:

            org.apache.kafka.common.errors.TimeoutException: Timed out while waiting to get end offsets for topic 'myTopic' on brokers at {retry.backoff.ms=0}

 

                Caused by:

                java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Timed out waiting to send the call. Call: listOffsets(api=METADATA)

                    at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395)

                    at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1999)

                    at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165)

                    at org.apache.kafka.connect.util.TopicAdmin.endOffsets(TopicAdmin.java:716)

                    at org.apache.kafka.connect.util.TopicAdmin.lambda$retryEndOffsets$7(TopicAdmin.java:769)

                    at org.apache.kafka.connect.util.RetryUtil.retryUntilTimeout(RetryUtil.java:87)

                    at org.apache.kafka.connect.util.RetryUtil.retryUntilTimeout(RetryUtil.java:56)

                    at org.apache.kafka.connect.util.TopicAdmin.retryEndOffsets(TopicAdmin.java:768)

                    at org.apache.kafka.connect.util.TopicAdminTest.retryEndOffsetsShouldRetryWhenTopicNotFound(TopicAdminTest.java:570)

 

                    Caused by:

                    org.apache.kafka.common.errors.TimeoutException: Timed out waiting to send the call. Call: listOffsets(api=METADATA)

Issue Links

• links to: GitHub Pull Request #14313