* Fixes #14906 - Kafka output dropping messages due to size, but does…

…n’t increment the “failed” counter. (#14930) (#14973)
elastic · Dec 9, 2019 · 3a6c77b · 3a6c77b
1 parent df4a03d
commit 3a6c77b
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/libbeat/outputs/kafka/client.go b/libbeat/outputs/kafka/client.go
@@ -254,11 +254,13 @@ func (r *msgRef) fail(msg *message, err error) {
 	switch err {
 	case sarama.ErrInvalidMessage:
 		logp.Err("Kafka (topic=%v): dropping invalid message", msg.topic)
+		r.client.observer.Dropped(1)
 
 	case sarama.ErrMessageSizeTooLarge, sarama.ErrInvalidMessageSize:
 		logp.Err("Kafka (topic=%v): dropping too large message of size %v.",
 			msg.topic,
 			len(msg.key)+len(msg.value))
+		r.client.observer.Dropped(1)
 
 	default:
 		r.failed = append(r.failed, msg.data)