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)
