From 5f0b5ab1a618fc00388ad8ba5317edf7aa49a9ca Mon Sep 17 00:00:00 2001 From: urso Date: Thu, 4 Feb 2021 21:54:30 +0100 Subject: [PATCH] Recover from panic in dgram handler --- filebeat/inputsource/common/dgram/server.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/filebeat/inputsource/common/dgram/server.go b/filebeat/inputsource/common/dgram/server.go index cec6f4fbab8..41a028f7d33 100644 --- a/filebeat/inputsource/common/dgram/server.go +++ b/filebeat/inputsource/common/dgram/server.go @@ -115,6 +115,8 @@ func (l *Listener) Start() error { } func (l *Listener) connectAndRun(ctx context.Context, conn net.PacketConn) error { + defer l.log.Recover("Panic handling datagram") + handler := l.connect(*l.config) for ctx.Err() == nil { err := handler(ctx, conn)