in pkg/esoutput/esoutput.go [213:220]
func (o *Output) Stop() error {
o.logger.Debug("Elasticsearch: stopping writing")
o.periodicFlusher.Stop()
if err := o.bulkIndexer.Close(context.Background()); err != nil {
log.Fatalf("Elasticsearch: Could not close bulk indexer: %s", err)
}
return nil
}