diff --git a/libbeat/outputs/discard/discard.go b/libbeat/outputs/discard/discard.go index a33462f5c2a7..c9a51b0f33df 100644 --- a/libbeat/outputs/discard/discard.go +++ b/libbeat/outputs/discard/discard.go @@ -56,7 +56,7 @@ func makeDiscard( // disable bulk support in publisher pipeline _ = cfg.SetInt("bulk_max_size", -1, -1) out.log.Infof("Initialized discard output") - return outputs.Success(doConfig.Queue, -1, 0, out) + return outputs.Success(doConfig.Queue, -1, 0, nil, out) } // Implement Outputer