feat: Add From<BrokerMessage<_>> impl for InvalidMessage (#377)

rust-arroyo/src/processing/strategies/mod.rs

@@ -1,4 +1,4 @@
-use crate::types::{Message, Partition};
+use crate::types::{BrokerMessage, Message, Partition};
 use std::collections::HashMap;
 use std::time::Duration;
 
@@ -27,6 +27,15 @@ pub struct InvalidMessage {
     pub offset: u64,
 }
 
+impl<TPayload> From<&BrokerMessage<TPayload>> for InvalidMessage {
+    fn from(value: &BrokerMessage<TPayload>) -> Self {
+        Self {
+            partition: value.partition,
+            offset: value.offset,
+        }
+    }
+}
+
 /// Signals that we need to commit offsets
 #[derive(Debug, Clone, PartialEq)]
 pub struct CommitRequest {