[jira] [Updated] (KAFKA-14368) Add an offset write REST API to Kafka Connect

2023-03-06 Thread Chris Egerton (Jira)


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

Chris Egerton updated KAFKA-14368:
--
Labels:   (was: kip-required)

> Add an offset write REST API to Kafka Connect
> -
>
> Key: KAFKA-14368
> URL: https://issues.apache.org/jira/browse/KAFKA-14368
> Project: Kafka
>  Issue Type: Sub-task
>Reporter: Yash Mayya
>Assignee: Yash Mayya
>Priority: Major
>
> Implement the {{PATCH /connectors/name/offsets}} endpoint [described in 
> KIP-875|https://cwiki.apache.org/confluence/display/KAFKA/KIP-875%3A+First-class+offsets+support+in+Kafka+Connect#KIP875:FirstclassoffsetssupportinKafkaConnect-Alteringoffsets].



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


[jira] [Updated] (KAFKA-14368) Add an offset write REST API to Kafka Connect

2023-03-06 Thread Chris Egerton (Jira)


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

Chris Egerton updated KAFKA-14368:
--
Description: Implement the {{PATCH /connectors/name/offsets}} endpoint 
[described in 
KIP-875|https://cwiki.apache.org/confluence/display/KAFKA/KIP-875%3A+First-class+offsets+support+in+Kafka+Connect#KIP875:FirstclassoffsetssupportinKafkaConnect-Alteringoffsets].
  (was: 
[KIP-875|https://cwiki.apache.org/confluence/display/KAFKA/KIP-875%3A+First-class+offsets+support+in+Kafka+Connect]
 for https://issues.apache.org/jira/browse/KAFKA-4107 proposes to add an offset 
reset API which will allow resetting the offsets for source and sink connectors 
so that they can consume from the beginning of the stream. However, an offset 
API to write arbitrary offsets would also be useful for certain connectors in 
order to go back in time but not to the beginning, or to skip some problematic 
record and move forward. Based on the discussion thread for KIP-875 
[here|https://lists.apache.org/thread/m5bklnh5w4mwr9nbzrmfk0pftpxfjd02], it was 
determined that this could be done through a follow-up KIP if/when KIP-875 is 
adopted.)

> Add an offset write REST API to Kafka Connect
> -
>
> Key: KAFKA-14368
> URL: https://issues.apache.org/jira/browse/KAFKA-14368
> Project: Kafka
>  Issue Type: Sub-task
>Reporter: Yash Mayya
>Assignee: Yash Mayya
>Priority: Major
>  Labels: kip-required
>
> Implement the {{PATCH /connectors/name/offsets}} endpoint [described in 
> KIP-875|https://cwiki.apache.org/confluence/display/KAFKA/KIP-875%3A+First-class+offsets+support+in+Kafka+Connect#KIP875:FirstclassoffsetssupportinKafkaConnect-Alteringoffsets].



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


[jira] [Updated] (KAFKA-14368) Add an offset write REST API to Kafka Connect

2023-03-06 Thread Chris Egerton (Jira)


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

Chris Egerton updated KAFKA-14368:
--
Parent: KAFKA-4107
Issue Type: Sub-task  (was: New Feature)

> Add an offset write REST API to Kafka Connect
> -
>
> Key: KAFKA-14368
> URL: https://issues.apache.org/jira/browse/KAFKA-14368
> Project: Kafka
>  Issue Type: Sub-task
>Reporter: Yash Mayya
>Assignee: Yash Mayya
>Priority: Major
>  Labels: kip-required
>
> [KIP-875|https://cwiki.apache.org/confluence/display/KAFKA/KIP-875%3A+First-class+offsets+support+in+Kafka+Connect]
>  for https://issues.apache.org/jira/browse/KAFKA-4107 proposes to add an 
> offset reset API which will allow resetting the offsets for source and sink 
> connectors so that they can consume from the beginning of the stream. 
> However, an offset API to write arbitrary offsets would also be useful for 
> certain connectors in order to go back in time but not to the beginning, or 
> to skip some problematic record and move forward. Based on the discussion 
> thread for KIP-875 
> [here|https://lists.apache.org/thread/m5bklnh5w4mwr9nbzrmfk0pftpxfjd02], it 
> was determined that this could be done through a follow-up KIP if/when 
> KIP-875 is adopted.



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