Skip to content

Commit

Permalink
Prevent panic when marking the offset in kafka_consumer (#5118)
Browse files Browse the repository at this point in the history
(cherry picked from commit d0a6051)
  • Loading branch information
glinton authored and danielnelson committed Dec 11, 2018
1 parent 2c0e0ec commit ae3f604
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions plugins/inputs/kafka_consumer/kafka_consumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -267,6 +267,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() {
Expand Down

0 comments on commit ae3f604

Please sign in to comment.