[ https://issues.apache.org/jira/browse/KAFKA-16621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
yuzhou updated KAFKA-16621: --------------------------- 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"}` !image-2024-04-25-21-28-37-375.png! 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} was: 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"}` !image-2024-04-25-21-28-37-375.png! 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} > Alter MirrorSourceConnector offsets dont work > --------------------------------------------- > > Key: KAFKA-16621 > URL: https://issues.apache.org/jira/browse/KAFKA-16621 > Project: Kafka > Issue Type: Bug > Components: connect > Reporter: yuzhou > Priority: Major > Attachments: image-2024-04-25-21-28-37-375.png > > > 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"}` > !image-2024-04-25-21-28-37-375.png! > 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} > > -- This message was sent by Atlassian Jira (v8.20.10#820010)