diff --git a/src/sentry/sentry_metrics/consumers/indexer/batch.py b/src/sentry/sentry_metrics/consumers/indexer/batch.py
index 3d3b1251d9b2d5..503cf357946efa 100644
--- a/src/sentry/sentry_metrics/consumers/indexer/batch.py
+++ b/src/sentry/sentry_metrics/consumers/indexer/batch.py
@@ -410,10 +410,6 @@ def reconstruct_messages(
                     fetch_types_encountered.add(metadata.fetch_type)
                     output_message_meta[metadata.fetch_type.value][str(metadata.id)] = tag
 
-            mapping_header_content = bytes(
-                "".join(sorted(t.value for t in fetch_types_encountered)), "utf-8"
-            )
-
             numeric_metric_id = mapping[use_case_id][org_id][metric_name]
             if numeric_metric_id is None:
                 metadata = bulk_record_meta[use_case_id][org_id].get(metric_name)
@@ -501,12 +497,7 @@ def reconstruct_messages(
                     kafka_payload = KafkaPayload(
                         key=message.payload.key,
                         value=rapidjson.dumps(new_payload_value).encode(),
-                        headers=[
-                            *message.payload.headers,
-                            ("mapping_sources", mapping_header_content),
-                            # XXX: type mismatch, but seems to work fine in prod
-                            ("metric_type", new_payload_value["type"]),  # type: ignore
-                        ],
+                        headers=[],
                     )
                 if self.is_output_sliced:
                     routing_payload = RoutingPayload(
diff --git a/tests/sentry/sentry_metrics/test_gen_metrics_multiprocess_steps.py b/tests/sentry/sentry_metrics/test_gen_metrics_multiprocess_steps.py
index a5cff4381f66c2..3d8a2ac55ddbfb 100644
--- a/tests/sentry/sentry_metrics/test_gen_metrics_multiprocess_steps.py
+++ b/tests/sentry/sentry_metrics/test_gen_metrics_multiprocess_steps.py
@@ -63,11 +63,6 @@ def compare_messages_ignoring_mapping_metadata(actual: Message, expected: Messag
 
     assert actual_payload.key == expected_payload.key
 
-    actual_headers_without_mapping_sources = [
-        (k, v.encode()) for k, v in actual_payload.headers if k != "mapping_sources"
-    ]
-    assert actual_headers_without_mapping_sources == expected_payload.headers
-
     actual_deserialized = json.loads(actual_payload.value)
     expected_deserialized = json.loads(expected_payload.value)
     del actual_deserialized["mapping_meta"]
diff --git a/tests/sentry/sentry_metrics/test_rh_metrics_multiprocess_steps.py b/tests/sentry/sentry_metrics/test_rh_metrics_multiprocess_steps.py
index 5ca349c9d65460..63d7a1005f8e2f 100644
--- a/tests/sentry/sentry_metrics/test_rh_metrics_multiprocess_steps.py
+++ b/tests/sentry/sentry_metrics/test_rh_metrics_multiprocess_steps.py
@@ -62,11 +62,6 @@ def compare_messages_ignoring_mapping_metadata(actual: Message, expected: Messag
 
     assert actual_payload.key == expected_payload.key
 
-    actual_headers_without_mapping_sources = [
-        (k, v.encode()) for k, v in actual_payload.headers if k != "mapping_sources"
-    ]
-    assert actual_headers_without_mapping_sources == expected_payload.headers
-
     actual_deserialized = json.loads(actual_payload.value)
     expected_deserialized = json.loads(expected_payload.value)
     del actual_deserialized["mapping_meta"]