Hi,
I have been stuck with this for some time now.
I have been implementing a custom sink connector in Java. For some purpose I want to get the taskId for a particular SinkTask Object. I have read the source code but I fail to find any field inside the SinkTask Object which could help me with this. One thing that is remotely linked to this is the SinkTaskContext but I am not sure if it stores the id.
Can anyone suggest something ?
This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.