yuzhou created KAFKA-16621: ------------------------------ Summary: 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 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: !image-2024-04-25-21-33-51-892.png! So alter offsets is not succussful, because when get offsets from globalOffsetBackingStore, always returns the first one. -- This message was sent by Atlassian Jira (v8.20.10#820010)