Prevent panic when marking the offset in kafka_consumer (#5118)

2018-12-10 16:55:58 -07:00
parent adce43f546
commit d0a6051fd7
1 changed files with 1 additions and 0 deletions
--- a/plugins/inputs/kafka_consumer/kafka_consumer.go
+++ b/plugins/inputs/kafka_consumer/kafka_consumer.go
@@ -275,6 +275,7 @@ func (k *Kafka) onDelivery(track telegraf.DeliveryInfo) {
 	msg, ok := k.messages[track.ID()]
 	if !ok {
 		log.Printf("E! [inputs.kafka_consumer] Could not mark message delivered: %d", track.ID())
+		return
 	}

 	if track.Delivered() {