vector.yaml aktualisiert

vector.yaml

@@ -9,18 +9,20 @@ sources:
 # TRANSFORMS: Verarbeitung der Daten
 # =============================================================================
 transforms:
-  # Schritt 1: Nur bestimmte Level durchlassen
   filter_debug:
     type: filter
     inputs: [docker_logs]
     condition: 'includes(["INFO", "WARN", "ERROR"], .level)'
 
-  # Schritt 2: Die gefilterten Logs formatieren (VRL)
   parse_logs:
     type: remap
-    inputs: [filter_debug] # Nimmt den Input vom Filter, nicht von der Source!
+    inputs: [filter_debug]
     source: |
-      .message = replace(.message, "\n", "")
+      # HIER IST DIE ÄNDERUNG: 
+      # Das ', err' fängt den Fehler ab, falls .message kein String ist.
+      # Wenn es fehlschlägt, bleibt .message einfach so, wie es war.
+      .message, err = replace(.message, "\n", "")
+      
       .service = "my-cluster"
 
 # =============================================================================