feat(kafka): add messaging.kafka.cluster.id to producer/consumer spans#4727

Open

shashank-reddy-nr wants to merge 9 commits into

open-telemetry:mainfrom

shashank-reddy-nr:feature/kafka-cluster-id

Commits on Jul 23, 2026

feat(kafka): emit messaging.kafka.cluster.id unconditionally across kafka-python, confluent-kafka, and aiokafka
shashank-reddy-nr
committed
feat(instrumentation/aiokafka): add messaging.kafka.cluster.id to producer/consumer spans
shashank-reddy-nr
committed
fix(instrumentation/aiokafka): move start wrappers inline to fix pyright/pylint
shashank-reddy-nr
committed
fix(instrumentation/aiokafka): move _patch_cluster_id_capture to __init__ to satisfy pyright
shashank-reddy-nr
committed
fix(instrumentation/aiokafka): correct changelog entry for PR 4727
shashank-reddy-nr
committed
fix(instrumentation/kafka-python): source cluster id from client metadata, not a separate admin client
shashank-reddy-nr
committed
fix: place PR 4727 changelog fragment in root .changelog/ for all three kafka packages
shashank-reddy-nr
committed
fix(instrumentation/kafka-python): keep test helper under pylint too-many-locals
shashank-reddy-nr
committed
refactor(kafka): rename cluster-id constant to _MESSAGING_KAFKA_CLUSTER_ID + add semconv TODO
shashank-reddy-nr
committed