You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Jun Rao (JIRA)" <ji...@apache.org> on 2014/04/22 18:50:15 UTC

[jira] [Commented] (KAFKA-1412) transient unit test failure in ProducerSendTest.testAutoCreateTopic

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

Jun Rao commented on KAFKA-1412:
--------------------------------

The issue seems to be there is no resend in the test. We should configure enough retries (default to 0) and retry backoff time to allow metadata to be propagated to the broker after auto topic creation.

> transient unit test failure in ProducerSendTest.testAutoCreateTopic
> -------------------------------------------------------------------
>
>                 Key: KAFKA-1412
>                 URL: https://issues.apache.org/jira/browse/KAFKA-1412
>             Project: Kafka
>          Issue Type: Bug
>          Components: core
>    Affects Versions: 0.8.2
>            Reporter: Jun Rao
>   Original Estimate: 24h
>  Remaining Estimate: 24h
>
> Saw the following transient failure. 
> kafka.api.test.ProducerSendTest > testAutoCreateTopic FAILED
>     java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
>         at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.valueOrError(FutureRecordMetadata.java:56)
>         at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:43)
>         at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:25)
>         at kafka.api.test.ProducerSendTest.testAutoCreateTopic(ProducerSendTest.scala:254)
>         Caused by:
>         org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.



--
This message was sent by Atlassian JIRA
(v6.2#6252)