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
wrote:
> I'm generally +1 on this, although have a couple of
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 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
