feat(rust): Count schema validation failures (#5515)

getsentry · Feb 12, 2024 · 3f38e42 · 3f38e42
1 parent 2d61df4
commit 3f38e42
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/rust_snuba/src/strategies/processor.rs b/rust_snuba/src/strategies/processor.rs
@@ -148,7 +148,10 @@ impl<TResult: Clone, TNext: Clone> MessageProcessor<TResult, TNext> {
         self,
         message: Message<KafkaPayload>,
     ) -> Result<Message<TNext>, RunTaskError<anyhow::Error>> {
-        validate_schema(&message, &self.schema, self.enforce_schema)?;
+        if let Err(error) = validate_schema(&message, &self.schema, self.enforce_schema) {
+            counter!("snuba.consumer.schema_validation.failed");
+            return Err(error);
+        };
 
         let msg = match message.inner_message {
             InnerMessage::BrokerMessage(msg) => msg,