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
 	}