[
https://issues.apache.org/jira/browse/KAFKA-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17170819#comment-17170819
]
Stanislav Kozlovski commented on KAFKA-10353:
---------------------------------------------
Should be fixed as of KAFKA-10308 -
[https://github.com/apache/kafka/commit/67b87807b21548c7b5c675284438429d9f486ca0]
> Trogdor - Fix RoundTripWorker to not fail when the topic it's trying to
> create already exists
> ---------------------------------------------------------------------------------------------
>
> Key: KAFKA-10353
> URL: https://issues.apache.org/jira/browse/KAFKA-10353
> Project: Kafka
> Issue Type: Bug
> Reporter: Stanislav Kozlovski
> Priority: Major
>
> Trogdor's RoundTripWorker calls WorkerUtils#createTopics with a failOnCreate
> flag equal to true, making the code throw an exception if the topic already
> exists.
> [https://github.com/apache/kafka/blob/28b7d8e21656649fb09b09f9bacfe865b0ca133c/tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java#L149]
> This is prone to race conditions when scheduling multiple workers to start at
> the same time - only one will succeed in creating a topic and running the
> test, while the rest will end up with a fatal error
> This has also been seen to happen in the RoundTripFaultTest system test where
> a network exception can cause the CreateTopics request to reach Kafka but
> Trogdor retry it and hit a TopicAlreadyExists exception on the retry, failing
> the test.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
