diff --git a/src/adapter/event_stream/saga_stream.rs b/src/adapter/event_stream/saga_stream.rs
index e613e67..f8781de 100644
--- a/src/adapter/event_stream/saga_stream.rs
+++ b/src/adapter/event_stream/saga_stream.rs
@@ -61,7 +61,6 @@ pub async fn stream_events_to_saga(
             Ok(())
         }
         Err(error) => {
-            // Handle the error, optionally break the loop based on the error
             error!("Error: {}", error.message);
             Err(ErrorMessage {
                 message: error.message,
diff --git a/src/adapter/event_stream/view_stream.rs b/src/adapter/event_stream/view_stream.rs
index b5b30cc..ecb1af6 100644
--- a/src/adapter/event_stream/view_stream.rs
+++ b/src/adapter/event_stream/view_stream.rs
@@ -92,7 +92,6 @@ pub async fn stream_events_to_view(
             Ok(())
         }
         Err(error) => {
-            // Handle the error
             error!("Error: {}", error.message);
             Err(ErrorMessage {
                 message: error.message,