diff --git a/publisher/bulk.go b/publisher/bulk.go index a02615ecd85..17b298a35b4 100644 --- a/publisher/bulk.go +++ b/publisher/bulk.go @@ -62,7 +62,9 @@ func (b *bulkWorker) run() { b.publish() } case <-b.flushTicker.C: - b.publish() + if len(b.events) > 0 { + b.publish() + } } } }