From 0a506a93fe1b55944d01900deaca1a21ad812376 Mon Sep 17 00:00:00 2001
From: Daniel Nelson <daniel@wavesofdawn.com>
Date: Thu, 29 Nov 2018 12:58:48 -0800
Subject: [PATCH] Remove metrics from the buffer on write (#5052)

---
 internal/models/buffer.go | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/internal/models/buffer.go b/internal/models/buffer.go
index 6848c26fa..8c03db3d4 100644
--- a/internal/models/buffer.go
+++ b/internal/models/buffer.go
@@ -175,9 +175,10 @@ func (b *Buffer) Accept(batch []telegraf.Metric) {
 		b.metricWritten(m)
 	}
 
-	if b.batchSize > 0 {
-		b.size -= b.batchSize
-		b.first += b.batchSize
+	b.size -= b.batchSize
+	for i := 0; i < b.batchSize; i++ {
+		b.buf[b.first] = nil
+		b.first++
 		b.first %= b.cap
 	}