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)