Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-9218

MirrorMaker 2 can fail to create topics

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 2.5.0
    • Component/s: None
    • Labels:
      None

      Description

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                mimaison Mickael Maison
                Reporter:
                mimaison Mickael Maison
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: