diff --git a/src/main.rs b/src/main.rs
index 75e0836..8dbb6f9 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -75,6 +75,7 @@ async fn run_sender(
                 _ = notify.notified() => break 'outer,
                 r = req.send() => {
                     if let Err(e) = r {
+                        counter!("sender_http_check_errors_count").increment(1);
                         error!("Error in HTTP request: {}", e);
                         tokio::select! {
                             _ = notify.notified() => break 'outer,
@@ -102,6 +103,7 @@ async fn run_sender(
             .body(body);
         info!("Starting HTTP sender stream");
         if let Err(e) = req.send().await {
+            counter!("sender_http_stream_errors_count").increment(1);
             error!("HTTP request error: {}", e);
             if let Err(e) = handle.await {
                 error!("Error in sender: {}", e);
@@ -225,6 +227,18 @@ fn setup_metrics(
         "Total number of non-UTF8 messages ignored"
     );
 
+    metrics::counter!("sender_http_stream_errors_count").absolute(0);
+    metrics::describe_counter!(
+        "sender_http_stream_errors_count",
+        "Total number of HTTP errors encountered while streaming messages",
+    );
+
+    metrics::counter!("sender_http_check_errors_count").absolute(0);
+    metrics::describe_counter!(
+        "sender_http_check_errors_count",
+        "Total number of HTTP errors encountered during preflight checks",
+    );
+
     Ok(())
 }