You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Konstantine Karantasis (Jira)" <ji...@apache.org> on 2020/03/29 02:30:00 UTC
[jira] [Updated] (KAFKA-7444) expose connector, task IDs to
SinkTasks
[ 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)