diff --git a/tests/sentry/ingest/ingest_consumer/test_ingest_consumer_kafka.py b/tests/sentry/ingest/ingest_consumer/test_ingest_consumer_kafka.py
index 5dd98f49b43875..9dcb57419d2f85 100644
--- a/tests/sentry/ingest/ingest_consumer/test_ingest_consumer_kafka.py
+++ b/tests/sentry/ingest/ingest_consumer/test_ingest_consumer_kafka.py
@@ -15,10 +15,15 @@
 from sentry.services.eventstore.processing import event_processing_store
 from sentry.testutils.pytest.fixtures import django_db_all
 from sentry.testutils.skips import requires_kafka, requires_snuba
+from sentry.testutils.thread_leaks.pytest import thread_leak_allowlist
 from sentry.utils.batching_kafka_consumer import create_topics
 from sentry.utils.kafka_config import get_topic_definition
 
-pytestmark = [requires_snuba, requires_kafka]
+pytestmark = [
+    requires_snuba,
+    requires_kafka,
+    thread_leak_allowlist(reason="ingest consumers", issue=97037),
+]
 
 logger = logging.getLogger(__name__)
 
diff --git a/tests/sentry/ingest/ingest_consumer/test_ingest_consumer_transactions.py b/tests/sentry/ingest/ingest_consumer/test_ingest_consumer_transactions.py
index 9ec688ce13b872..11bd45196651fc 100644
--- a/tests/sentry/ingest/ingest_consumer/test_ingest_consumer_transactions.py
+++ b/tests/sentry/ingest/ingest_consumer/test_ingest_consumer_transactions.py
@@ -14,6 +14,7 @@
 from sentry.services import eventstore
 from sentry.testutils.pytest.fixtures import django_db_all
 from sentry.testutils.skips import requires_kafka, requires_snuba
+from sentry.testutils.thread_leaks.pytest import thread_leak_allowlist
 from sentry.utils.batching_kafka_consumer import create_topics
 from sentry.utils.kafka_config import get_topic_definition
 
@@ -71,6 +72,7 @@ def random_group_id() -> str:
 
 @django_db_all(transaction=True)
 @pytest.mark.parametrize("no_celery_mode", [True, False])
+@thread_leak_allowlist(reason="ingest consumers", issue=97037)
 def test_ingest_consumer_reads_from_topic_and_saves_event(
     no_celery_mode,
     task_runner,