conduktor.io ↗

KIP-803 — Add Task ID and Connector Name to Connect Task Context

Discussion ConnectMetrics

Exposes the task ID and connector name to `SourceTask` and `SinkTask` implementations via the `TaskContext` interface so connectors can use them for custom metrics, logging, or debugging. While KIP-449 added these values to the SLF4J MDC for log enrichment, there was no programmatic API for connectors to access them directly.

Details

AuthorSarah Story
StatusDiscussion
JIRAKAFKA-13477
WikiView on Apache Wiki
Created2021-11-24
Last Modified2021-11-24
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.