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

)
dupondje · Apr 22, 2019 · 7166402 · 7166402
1 parent a5de897
commit 7166402
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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() {