You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Yash Mayya (Jira)" <ji...@apache.org> on 2023/03/07 18:11:00 UTC

[jira] [Assigned] (KAFKA-14786) Implement connector offset write/reset internal logic

     [ https://issues.apache.org/jira/browse/KAFKA-14786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Yash Mayya reassigned KAFKA-14786:
----------------------------------

    Assignee: Yash Mayya

> Implement connector offset write/reset internal logic
> -----------------------------------------------------
>
>                 Key: KAFKA-14786
>                 URL: https://issues.apache.org/jira/browse/KAFKA-14786
>             Project: Kafka
>          Issue Type: Sub-task
>          Components: KafkaConnect
>            Reporter: Chris Egerton
>            Assignee: Yash Mayya
>            Priority: Major
>
> Implement the internal logic necessary for altering/resetting the offsets of connectors, [described in KIP-875|https://cwiki.apache.org/confluence/display/KAFKA/KIP-875%3A+First-class+offsets+support+in+Kafka+Connect#KIP875:FirstclassoffsetssupportinKafkaConnect-Endpointsbehavior].
> This should not include any changes to public interface except the introduction of the new {{SourceConnector::alterOffsets}} and {{SinkConnector::alterOffsets}} methods (i.e., it should not expose or test any new REST endpoints).
> Ideally, we'll separate this from KAFKA-14368, KAFKA-14784, and KAFKA-14785 by making all changes here target the internal Connect {{Herder}} interface, and have the changes for the other three rely on those new {{Herder}} methods.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)