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() {