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