[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)
