topbeat close publisher.Client on stop

elastic · Apr 19, 2016 · 18be356 · 18be356
1 parent 8ce0a6e
commit 18be356
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/topbeat/beater/topbeat.go b/topbeat/beater/topbeat.go
@@ -172,4 +172,5 @@ func (tb *Topbeat) Cleanup(b *beat.Beat) error {
 func (t *Topbeat) Stop() {
 	logp.Info("Send stop signal to topbeat main loop")
 	close(t.done)
+	t.events.Close()
 }