You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by Ryanne Dolan <ry...@gmail.com> on 2019/03/05 17:38:10 UTC

[DISCUSS] KIP-438: Expose task, connector IDs in Connect API

Hey y'all, please consider the following small KIP:

https://cwiki.apache.org/confluence/display/KAFKA/KIP-438%3A+Expose+task%2C+connector+IDs+in+Connect+API

Thanks!
Ryanne

Re: [DISCUSS] KIP-438: Expose task, connector IDs in Connect API

Posted by Ryanne Dolan <ry...@gmail.com>.

Thanks Viktor. Yes to both.

ConnectorTaskId (which includes both connector name and task ID) is
accessible from both WorkerSource/SinkTaskContext, so this change is
trivial.

Ryanne

On Tue, Mar 19, 2019 at 9:26 AM Viktor Somogyi-Vass <vi...@gmail.com>
wrote:

> I'm generally +1 on this, although have a couple of basic questions.
> Am I getting that right that you basically want to expose the task id from
> ConnectorTaskId? And if so, then I guess you'll provide the implementation
> too?
>
> Thanks,
> Viktor
>
> On Tue, Mar 5, 2019 at 6:49 PM Ryanne Dolan <ry...@gmail.com> wrote:
>
> > Hey y'all, please consider the following small KIP:
> >
> >
> >
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-438%3A+Expose+task%2C+connector+IDs+in+Connect+API
> >
> > Thanks!
> > Ryanne
> >
>

Re: [DISCUSS] KIP-438: Expose task, connector IDs in Connect API

Posted by Viktor Somogyi-Vass <vi...@gmail.com>.

I'm generally +1 on this, although have a couple of basic questions.
Am I getting that right that you basically want to expose the task id from
ConnectorTaskId? And if so, then I guess you'll provide the implementation
too?

Thanks,
Viktor

On Tue, Mar 5, 2019 at 6:49 PM Ryanne Dolan <ry...@gmail.com> wrote:

> Hey y'all, please consider the following small KIP:
>
>
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-438%3A+Expose+task%2C+connector+IDs+in+Connect+API
>
> Thanks!
> Ryanne
>