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

Alter MirrorSourceConnector offsets dont work

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Not A Bug
    • None
    • None
    • connect
    • None

    Description

      In connect-offsets topic:

      the offsets wrote by connector, key is `{"cluster":"A","partition":2,"topic":"topic"}`

      after alter offsets, the key is  `{"partition":2,"topic":"topic","cluster":"A"}`

      in Worker.globalOffsetBackingStore.data, both two keys exist, because the are different strings:

      {"cluster":"A","partition":2,"topic":"topic"} {"offset":2}

       

      {"partition":2,"topic":"topic","cluster":"A"}{"offset":3}

      So alter offsets is not succussful, because when get offsets from globalOffsetBackingStore, always returns 

      {"offset":2}

       

       

      Attachments

        Activity

          People

            Unassigned Unassigned
            yuzhou yuzhou
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: