[KAFKA-16621] Alter MirrorSourceConnector offsets dont work

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Not A Bug
• Component/s: connect
• Assignee: Unassigned
• Reporter: yuzhou
• Created: 25/Apr/24 13:37
• Updated: 26/Apr/24 09:36
• Resolved: 26/Apr/24 09:36

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}