[ https://issues.apache.org/jira/browse/KAFKA-3217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15136688#comment-15136688 ]
Ismael Juma commented on KAFKA-3217: ------------------------------------ Nice find! > Unit tests which dont close producers auto-create topics in Kafka brokers of > other tests when port is reused > ------------------------------------------------------------------------------------------------------------ > > Key: KAFKA-3217 > URL: https://issues.apache.org/jira/browse/KAFKA-3217 > Project: Kafka > Issue Type: Bug > Components: unit tests > Affects Versions: 0.9.0.0 > Reporter: Rajini Sivaram > Assignee: Rajini Sivaram > > Consumer tests occasionally fail the exception: > {quote} > kafka.common.TopicExistsException: Topic "topic" already exists. > at > kafka.admin.AdminUtils$.createOrUpdateTopicPartitionAssignmentPathInZK(AdminUtils.scala:261) > at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:245) > at kafka.utils.TestUtils$.createTopic(TestUtils.scala:237) > at kafka.api.BaseConsumerTest.setUp(BaseConsumerTest.scala:65) > {quote} > Recreated this failure with some additional logging and it turns out that the > failure is because a few tests which create a topic named "topic" close their > Kafka server, but not the producer. When the ephemeral port used by the > closed Kafka server gets reused in another Kafka server in a subsequent test, > the producer retries of the previous test cause "topic" to be recreated using > auto-create in the new Kafka server of the subsequent test. This results in > an error in the consumer tests occasionally when the topic is auto-created > before the test attempts to create it. -- This message was sent by Atlassian JIRA (v6.3.4#6332)