From c73c1dfe6b390d3cefce330f10b0e4f4c4536ec2 Mon Sep 17 00:00:00 2001
From: Lou Knauer <lou.knauer@gmx.de>
Date: Thu, 10 Feb 2022 09:00:36 +0100
Subject: [PATCH] Add error handling for Sink.Write

---
 sinks/sinkManager.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/sinks/sinkManager.go b/sinks/sinkManager.go
index 80877c8..bbff949 100644
--- a/sinks/sinkManager.go
+++ b/sinks/sinkManager.go
@@ -106,7 +106,9 @@ func (sm *sinkManager) Start() {
 				// Send received metric to all outputs
 				cclog.ComponentDebug("SinkManager", "WRITE", p)
 				for _, s := range sm.sinks {
-					s.Write(p)
+					if err := s.Write(p); err != nil {
+						cclog.ComponentError("SinkManager", "WRITE", s.Name(), "write failed:", err.Error())
+					}
 				}
 			}
 		}