[ https://issues.apache.org/jira/browse/KAFKA-15416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chris Egerton updated KAFKA-15416: ---------------------------------- Fix Version/s: (was: 3.7.0) > Flaky test TopicAdminTest::retryEndOffsetsShouldRetryWhenTopicNotFound > ---------------------------------------------------------------------- > > Key: KAFKA-15416 > URL: https://issues.apache.org/jira/browse/KAFKA-15416 > Project: Kafka > Issue Type: Test > Components: KafkaConnect > Reporter: Chris Egerton > Assignee: Chris Egerton > Priority: Minor > Fix For: 3.6.0 > > > This test fails frequently when I run unit tests locally, but I've never seen > it fail during a CI build. > Failure message: > {quote} 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) > {quote} -- This message was sent by Atlassian Jira (v8.20.10#820010)