diff --git a/libbeat/publisher/pipeline/module.go b/libbeat/publisher/pipeline/module.go index 4d3c8bd9caf5..4fb5282f5825 100644 --- a/libbeat/publisher/pipeline/module.go +++ b/libbeat/publisher/pipeline/module.go @@ -134,6 +134,10 @@ func loadOutput( monitoring.NewString(outReg, "type").Set(outcfg.Name()) } + stateRegistry := monitoring.GetNamespace("state").GetRegistry() + outputRegistry := stateRegistry.NewRegistry("output") + monitoring.NewString(outputRegistry, "name").Set(outcfg.Name()) + return out, nil }