diff --git a/snuba/web/views.py b/snuba/web/views.py
index 2b30836bf2..7cbde9d50e 100644
--- a/snuba/web/views.py
+++ b/snuba/web/views.py
@@ -621,6 +621,9 @@ def eventstream(*, entity: Entity) -> RespTuple:
 
         storage = entity.get_writable_storage()
         assert storage is not None
+        storage_name = storage.get_storage_key().value
+        # TODO: A few storages are currently excluded from schema validation
+        should_validate_schema = storage_name not in ["search_issues", "replays"]
 
         try:
             if type_ == "insert":
@@ -644,7 +647,7 @@ def commit(
                         stream_loader.get_processor(),
                         "consumer_grouup",
                         stream_loader.get_default_topic_spec().topic,
-                        False,
+                        should_validate_schema,
                     ),
                     build_batch_writer(table_writer, metrics=metrics),
                     max_batch_size=1,