Thanks for KIP Chris - I think this is a useful feature. Can you please elaborate on the following in the KIP -
1. How would the response of GET /connectors/{connector}/offsets look like if the worker has both global and connector specific offsets topic ? 2. How can we pass the reset options like shift-by , to-date-time etc. using a REST API like DELETE /connectors/{connector}/offsets ? 3. Today PAUSE operation on a connector invokes its stop method - will there be a change here to reduce confusion with the new proposed STOPPED state ? Thanks, Ashwin On Fri, Oct 14, 2022 at 2:22 AM Chris Egerton <chr...@aiven.io.invalid> wrote: > Hi all, > > I noticed a fairly large gap in the first version of this KIP that I > published last Friday, which has to do with accommodating connectors > that target different Kafka clusters than the one that the Kafka Connect > cluster uses for its internal topics and source connectors with dedicated > offsets topics. I've since updated the KIP to address this gap, which has > substantially altered the design. Wanted to give a heads-up to anyone > that's already started reviewing. > > Cheers, > > Chris > > On Fri, Oct 7, 2022 at 1:29 PM Chris Egerton <chr...@aiven.io> wrote: > > > Hi all, > > > > I'd like to begin discussion on a KIP to add offsets support to the Kafka > > Connect REST API: > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-875%3A+First-class+offsets+support+in+Kafka+Connect > > > > Cheers, > > > > Chris > > >