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

[jira] [Assigned] (KAFKA-5948) EosIntegrationTest fails with TopicAlreadyMarkedForDeletionException

     [ https://issues.apache.org/jira/browse/KAFKA-5948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Bruno Cadonna reassigned KAFKA-5948:
------------------------------------

    Assignee: Bruno Cadonna

> EosIntegrationTest fails with TopicAlreadyMarkedForDeletionException
> --------------------------------------------------------------------
>
>                 Key: KAFKA-5948
>                 URL: https://issues.apache.org/jira/browse/KAFKA-5948
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams, unit tests
>    Affects Versions: 0.11.0.1
>            Reporter: Matthias J. Sax
>            Assignee: Bruno Cadonna
>            Priority: Major
>
> Seem to be a test setup race condition:
> {noformat}
> kafka.common.TopicAlreadyMarkedForDeletionException: topic singlePartitionThroughTopic is already marked for deletion
> 	at kafka.admin.AdminUtils$.deleteTopic(AdminUtils.scala:340)
> 	at kafka.admin.AdminUtils.deleteTopic(AdminUtils.scala)
> 	at org.apache.kafka.streams.integration.utils.KafkaEmbedded.deleteTopic(KafkaEmbedded.java:200)
> 	at org.apache.kafka.streams.integration.utils.EmbeddedKafkaCluster.deleteTopicsAndWait(EmbeddedKafkaCluster.java:268)
> 	at org.apache.kafka.streams.integration.utils.EmbeddedKafkaCluster.deleteTopicsAndWait(EmbeddedKafkaCluster.java:256)
> 	at org.apache.kafka.streams.integration.EosIntegrationTest.createTopics(EosIntegrationTest.java:102)
> {noformat}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)