diff --git a/libbeat/publisher/beat/pipeline.go b/libbeat/publisher/beat/pipeline.go
index c74e8c2d947..86023601fa3 100644
--- a/libbeat/publisher/beat/pipeline.go
+++ b/libbeat/publisher/beat/pipeline.go
@@ -72,9 +72,9 @@ type ClientEventer interface {
 	Closing() // Closing indicates the client is being shutdown next
 	Closed()  // Closed indicates the client being fully shutdown
 
-	Published()             // event been has successfully forwarded to the publisher pipeline
+	Published()             // event has been successfully forwarded to the publisher pipeline
 	FilteredOut(Event)      // event has been filtered out/dropped by processors
-	DroppedOnPublish(Event) // event has been dropped, while waiting for the broker
+	DroppedOnPublish(Event) // event has been dropped, while waiting for the queue
 }
 
 // PipelineACKHandler configures some pipeline-wide event ACK handler.