[
https://issues.apache.org/jira/browse/KAFKA-7444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-7444:
------------------------------------------
Labels: needs-kip (was: newbie)
> expose connector, task IDs to SinkTasks
> ---------------------------------------
>
> Key: KAFKA-7444
> URL: https://issues.apache.org/jira/browse/KAFKA-7444
> Project: Kafka
> Issue Type: Improvement
> Components: KafkaConnect
> Affects Versions: 2.0.0
> Reporter: Ryanne Dolan
> Assignee: Ryanne Dolan
> Priority: Minor
> Labels: needs-kip
>
> SinkTasks don't have access to their ConnectorTaskId, which would be useful
> for logging and for using SinkUtils.consumerGroupId(id).
>
> I suggest an id() method be added to SinkTaskContext and
> WorkerSinkTaskContext.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)