From fb11756ddd5e80edcb6ddf1144542508b072f7ac Mon Sep 17 00:00:00 2001 From: Cagri Yonca Date: Mon, 8 Sep 2025 16:52:14 +0200 Subject: [PATCH] fix: fixed reading suppression header from message's headers Signed-off-by: Cagri Yonca --- src/instana/instrumentation/kafka/kafka_python.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/instana/instrumentation/kafka/kafka_python.py b/src/instana/instrumentation/kafka/kafka_python.py index c11e9355..3b1423d3 100644 --- a/src/instana/instrumentation/kafka/kafka_python.py +++ b/src/instana/instrumentation/kafka/kafka_python.py @@ -51,6 +51,9 @@ def trace_kafka_send( # context propagation headers = kwargs.get("headers", []) + if not is_suppressed and ("x_instana_l_s", b"0") in headers: + is_suppressed = True + suppression_header = {"x_instana_l_s": "0" if is_suppressed else "1"} headers.append(suppression_header) @@ -96,10 +99,8 @@ def create_span( ) if not is_suppressed and headers: - for header_name, header_value in headers: - if header_name == "x_instana_l_s" and header_value == b"0": - is_suppressed = True - break + if ("x_instana_l_s", b"0") in headers: + is_suppressed = True if is_suppressed: return