Abort on the commit log not being able to consume (#124)

We now abort if there are problems read from the commit log. All bets are off. If a problem occurs due to the data format having changed then it is on the programmer to upgrade the deserialisation.

akka-persistence-rs-commitlog/src/lib.rs

@@ -8,7 +8,6 @@ use akka_persistence_rs::{
 use async_stream::stream;
 use async_trait::async_trait;
 use chrono::{DateTime, Utc};
-use log::warn;
 use serde::{de::DeserializeOwned, Serialize};
 use std::{io, marker::PhantomData, pin::Pin, sync::Arc};
 use streambed::{
@@ -358,7 +357,7 @@ where
                                 );
                             }
                             Err(e) => {
-                                warn!("When initially consuming: {e:?}");
+                                panic!("When initially consuming: {e:?}. Having to abort as this is unrecoverable.");
                             }
                         }
                     }
@@ -398,7 +397,7 @@ where
                                     );
                                 }
                                 Err(e) => {
-                                    warn!("When consuming: {e:?}");
+                                    panic!("When consuming: {e:?}. Having to abort as this is unrecoverable.");
                                 }
                             }
                         }