ref(crons): Remove decode compat code

This issue is no longer happening [SENTRY-38FS](https://sentry.sentry.io/issues/5256667522/)

Author: evanpurkhiser

src/sentry/monitors/consumers/monitor_consumer.py

@@ -9,7 +9,6 @@
 from functools import partial
 from typing import Literal
 
-import msgpack
 import sentry_sdk
 from arroyo.backends.kafka.consumer import KafkaPayload
 from arroyo.processing.strategies.abstract import ProcessingStrategy, ProcessingStrategyFactory
@@ -864,11 +863,7 @@ def process_batch(executor: ThreadPoolExecutor, message: Message[ValuesBatch[Kaf
         assert isinstance(item, BrokerValue)
 
         try:
-            try:
-                wrapper: IngestMonitorMessage = MONITOR_CODEC.decode(item.payload.value)
-            except ValidationError:
-                wrapper = msgpack.unpackb(item.payload.value)
-                logger.exception("Failed to unpack message payload via sentry_kafka_schemas")
+            wrapper: IngestMonitorMessage = MONITOR_CODEC.decode(item.payload.value)
         except Exception:
             logger.exception("Failed to unpack message payload")
             continue
@@ -913,12 +908,7 @@ def process_batch(executor: ThreadPoolExecutor, message: Message[ValuesBatch[Kaf
 def process_single(message: Message[KafkaPayload]):
     assert isinstance(message.value, BrokerValue)
     try:
-        try:
-            wrapper: IngestMonitorMessage = MONITOR_CODEC.decode(message.payload.value)
-        except ValidationError:
-            logger.exception("Failed to unpack message payload via sentry_kafka_schemas")
-            wrapper = msgpack.unpackb(message.payload.value)
-
+        wrapper: IngestMonitorMessage = MONITOR_CODEC.decode(message.payload.value)
         ts = message.value.timestamp
         partition = message.value.partition.index