conduktor.io ↗

KIP-438 — Expose task, connector IDs in Connect API

Discussion ConnectAdmin

Exposes the task ID and connector name to `SourceTask` and `SinkTask` implementations via a `TaskContext` object passed to `initialize()`, allowing connector code to include its own task identity in log messages and custom metrics. Connect tasks currently lack programmatic access to their assigned task ID, making connector-generated logs and metrics unattributable to the specific task instance.

Details

AuthorRyanne Dolan
StatusDiscussion
WikiView on Apache Wiki
Created2019-03-04
Last Modified2019-03-05
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.