[jira] [Resolved] (KAFKA-16621) Alter MirrorSourceConnector offsets dont work
[ 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)
[jira] [Created] (KAFKA-16621) Alter MirrorSourceConnector offsets dont work
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)
[jira] [Created] (KAFKA-10814) improving ability of handling exception in kafka
yuzhou created KAFKA-10814: -- Summary: improving ability of handling exception in kafka Key: KAFKA-10814 URL: https://issues.apache.org/jira/browse/KAFKA-10814 Project: Kafka Issue Type: Wish Components: streams Reporter: yuzhou When i use kafka streams,an exception such as NullPointerException runtime exception occured in a processor,which i can't caught in it,the whole streams was shuttdown,and other streams app would shuttdown either. When use common tomcat handle request,excepiton just throw,not shuttdown application,and not effect other request forward. -- This message was sent by Atlassian Jira (v8.3.4#803005)