From d0a6051fd73dbd43470b4313a63c9dc201aebbcc Mon Sep 17 00:00:00 2001
From: Greg <2653109+glinton@users.noreply.github.com>
Date: Mon, 10 Dec 2018 16:55:58 -0700
Subject: [PATCH] Prevent panic when marking the offset in kafka_consumer
 (#5118)

---
 plugins/inputs/kafka_consumer/kafka_consumer.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/plugins/inputs/kafka_consumer/kafka_consumer.go b/plugins/inputs/kafka_consumer/kafka_consumer.go
index 0814d8e14..545e37f5a 100644
--- 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() {