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

TopicBased RemoteLogMetadataManager can't support reassign user-partitions

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • None
    • core
    • None

    Description

      Background:
      In KIP-405: Kafka Tiered Storage - Apache Kafka - Apache Software Foundation,  kafka introduced the feature of hierarchical storage.
      Also, KAFKA-9555 Topic-based implementation for the RemoteLogMetadataManager - ASF JIRA (apache.org) implements the default RLMM - 'TopicBased-RLMM'.

      Problem:
      TopicBased-RLMM will only subscribe to the Partitions where the current Broker is Leader or Follower. If the current Broker is not the Leader or Follower, then RLMM will directly skip the metadata records related to these Partitions.

      When reassign user-partitions occurs, rlmm will subscribe to new user-partitions, assuming that the metadata-partition to which the new user-partition belongs is 'metadata-partition0', and RLMM has consumed 'metadata-partition0' to offset = 100 before the reassign partition occurs, then after reassign, RMLM will not consume 'metadata-partition0' from the beginning, and finally cause the metadata records related to the new user-partition to be lost with offset < 100.

      Solution

      Let RLMM subscribe to all user-patitions, instead of only subscribing to partitions where the current broker is leader or follower.
      In this way, when reassign partition occurs, RLMM will have new partition's metadata records.

      Attachments

        Activity

          People

            hzh0425@apache hzh0425
            hzh0425@apache hzh0425
            Satish Duggana Satish Duggana
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: