[ https://issues.apache.org/jira/browse/KAFKA-16621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
yuzhou resolved KAFKA-16621. ---------------------------- Resolution: Not A Bug Fixed in KAFKA-15182: Normalize source connector offsets before invoking SourceConnector::alterOffsets (#14003) > 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)