diff --git a/probe/endpoint/conntrack.go b/probe/endpoint/conntrack.go index 155dfa41c..92678878e 100644 --- a/probe/endpoint/conntrack.go +++ b/probe/endpoint/conntrack.go @@ -147,6 +147,11 @@ func (c *conntrackWalker) run() { if !ok { return } + if f.Err != nil { + log.Errorf("conntrack event error: %v", f.Err) + stop() + return + } if c.relevant(f) { c.handleFlow(f) }