chore: drop event if event type is snapshot (we have migrated to snap…

…shot_items (#17558)

* chore: drop event if event type is snapshot (we have migrated to snapshot_items

* Add a comment

posthog/api/capture.py

@@ -29,7 +29,6 @@
 )
 from posthog.kafka_client.topics import (
     KAFKA_EVENTS_PLUGIN_INGESTION_HISTORICAL,
-    KAFKA_SESSION_RECORDING_EVENTS,
     KAFKA_SESSION_RECORDING_SNAPSHOT_ITEM_EVENTS,
 )
 from posthog.logging.timing import timed
@@ -142,8 +141,6 @@ def _kafka_topic(event_name: str, data: Dict) -> str:
     # and other events, we push to a different topic.
 
     match event_name:
-        case "$snapshot":
-            return KAFKA_SESSION_RECORDING_EVENTS
         case "$snapshot_items":
             return KAFKA_SESSION_RECORDING_SNAPSHOT_ITEM_EVENTS
         case _:
@@ -155,6 +152,11 @@ def _kafka_topic(event_name: str, data: Dict) -> str:
 
 
 def log_event(data: Dict, event_name: str, partition_key: Optional[str]):
+    if event_name == "$snapshot":
+        # This is deprecated and we should no longer spend any time producing
+        # these events to kafka.
+        return
+
     kafka_topic = _kafka_topic(event_name, data)
 
     logger.debug("logging_event", event_name=event_name, kafka_topic=kafka_topic)