fix(process-segments): Do not crash when messages are invalid (#91663)

We don't get much from crashing while this entire deployment is still a
noop.

Author: untitaker

src/sentry/spans/consumers/process_segments/factory.py

@@ -2,6 +2,7 @@
 from collections.abc import Mapping
 
 import orjson
+import sentry_sdk
 from arroyo import Topic as ArroyoTopic
 from arroyo.backends.kafka import KafkaProducer, build_kafka_configuration
 from arroyo.backends.kafka.consumer import KafkaPayload
@@ -107,12 +108,10 @@ def _process_message(message: Message[KafkaPayload]) -> list[bytes]:
         segment = orjson.loads(value)
         processed = process_segment(segment["spans"])
         return [orjson.dumps(span) for span in processed]
-    except Exception:  # NOQA
-        raise
-        # TODO: Implement error handling
-        # sentry_sdk.capture_exception()
-        # assert isinstance(message.value, BrokerValue)
-        # raise InvalidMessage(message.value.partition, message.value.offset)
+    except Exception:
+        # TODO: revise error handling
+        sentry_sdk.capture_exception()
+        return []
 
 
 def _unfold_segment(spans: list[bytes]):