Chris Egerton created KAFKA-15416: ------------------------------------- Summary: 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
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)