[ https://issues.apache.org/jira/browse/KAFKA-9218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Mickael Maison resolved KAFKA-9218. ----------------------------------- Fix Version/s: 2.5.0 Resolution: Fixed > 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 > Fix For: 2.5.0 > > > 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)