From 15075ce75757ffbc832c2fbcfb6f2a9e602d985c Mon Sep 17 00:00:00 2001
From: Jeff Cantrill <jcantril@redhat.com>
Date: Tue, 14 Jul 2026 16:46:04 -0400
Subject: [PATCH] fix(sink socket): fix regression for udp socket recovery
 after error

LOG-9560
---
 src/sinks/util/datagram.rs | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/src/sinks/util/datagram.rs b/src/sinks/util/datagram.rs
index 9fe37f761477a..a4cfc43edf9bb 100644
--- a/src/sinks/util/datagram.rs
+++ b/src/sinks/util/datagram.rs
@@ -47,6 +47,7 @@ pub async fn send_datagrams<E: Encoder<Event, Error = vector_lib::codecs::encodi
             continue;
         }
 
+        let mut socket_error = false;
         let delivered = if let Some(chunker) = chunker {
             let data_size = bytes.len();
             match chunker.chunk(bytes.freeze()) {
@@ -55,6 +56,7 @@ pub async fn send_datagrams<E: Encoder<Event, Error = vector_lib::codecs::encodi
                     for bytes in chunks {
                         if !send_and_emit(&mut socket, &bytes, bytes_sent).await {
                             chunks_delivered = false;
+                            socket_error = true;
                             break;
                         }
                     }
@@ -68,14 +70,20 @@ pub async fn send_datagrams<E: Encoder<Event, Error = vector_lib::codecs::encodi
                     false
                 }
             }
+        } else if send_and_emit(&mut socket, &bytes.freeze(), bytes_sent).await {
+            true
         } else {
-            send_and_emit(&mut socket, &bytes.freeze(), bytes_sent).await
+            socket_error = true;
+            false
         };
 
         if delivered {
             finalizers.update_status(EventStatus::Delivered);
         } else {
             finalizers.update_status(EventStatus::Errored);
+            if socket_error {
+                return;
+            }
         }
     }
 }