home/telegraf
2
0
Fork 0
mirror of https://github.com/wahyd4/telegraf.git synced 2026-08-09 04:36:05 +10:00
Code Issues Packages Projects Releases Wiki Activity

Fix could not mark message delivered error in kafka_consumer (#6363)

Browse Source 
(cherry picked from commit 76e7b57fcd)
This commit is contained in:
Daniel Nelson
2019-09-06 12:42:44 -07:00
parent 8838f6fd6e
commit 27310423ae
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/inputs/kafka_consumer/kafka_consumer.go
+1 -1
View File
@@ -360,8 +360,8 @@ func (h *ConsumerGroupHandler) Handle(session sarama.ConsumerGroupSession, msg *
}
}
id := h.acc.AddTrackingMetricGroup(metrics)
h.mu.Lock()
id := h.acc.AddTrackingMetricGroup(metrics)
h.undelivered[id] = Message{session: session, message: msg}
h.mu.Unlock()
return nil