[ https://issues.apache.org/jira/browse/KAFKA-9218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16979188#comment-16979188 ]
Edoardo Comar commented on KAFKA-9218: -------------------------------------- A similar issue would occur if a target was deleted, it would not be recreated by MM2 unless a new change in the source topics occurred > MirrorMaker 2 can fail to create topics > --------------------------------------- > > Key: KAFKA-9218 > URL: https://issues.apache.org/jira/browse/KAFKA-9218 > Project: Kafka > Issue Type: Bug > Reporter: Mickael Maison > Assignee: Mickael Maison > Priority: Major > > MirrorSourceConnector.refreshTopicPartitions() does not handle topic creation > failure correctly. > If createTopicPartitions() fails to create a topic, the next time > refreshTopicPartitions() it will not retry the creation. The creation will > only be retried if another topic has been created in the source cluster. This > is because knownTopicPartitions is updated before the topic creation is > attempted and it's only refreshed if a new topic appears. -- This message was sent by Atlassian Jira (v8.3.4#803005)