fix: suppression propagation in kafka

Signed-off-by: Varsha GS <[email protected]>

Author: GSVarsha

src/instana/propagators/kafka_propagator.py

@@ -103,7 +103,26 @@ def inject(
             # Suppression `level` made in the child context or in the parent context
             # has priority over any non-suppressed `level` setting
             suppression_level = int(self.extract_instana_headers(dictionary_carrier)[2])
-            span_context.level = min(suppression_level, span_context.level)
+            new_level = min(suppression_level, span_context.level)
+
+            if new_level != span_context.level:
+                # Create a new span context with the updated level
+                span_context = SpanContext(
+                    trace_id=span_context.trace_id,
+                    span_id=span_context.span_id,
+                    is_remote=span_context.is_remote,
+                    trace_flags=span_context.trace_flags,
+                    trace_state=span_context.trace_state,
+                    level=new_level,
+                    synthetic=span_context.synthetic,
+                    trace_parent=span_context.trace_parent,
+                    instana_ancestor=span_context.instana_ancestor,
+                    long_trace_id=span_context.long_trace_id,
+                    correlation_type=span_context.correlation_type,
+                    correlation_id=span_context.correlation_id,
+                    traceparent=span_context.traceparent,
+                    tracestate=span_context.tracestate
+                )
 
         def inject_key_value(carrier, key, value):
             if isinstance(carrier, list):
@@ -119,9 +138,9 @@ def inject_key_value(carrier, key, value):
             inject_key_value(
                 carrier,
                 self.KAFKA_HEADER_KEY_L_S,
-                str(suppression_level).encode("utf-8"),
+                str(span_context.level).encode("utf-8"),
             )
-            if suppression_level == 1:
+            if span_context.level == 1:
                 inject_key_value(
                     carrier,
                     self.KAFKA_HEADER_KEY_T,