From 1cc9491eca53b3823101c9da3f3a0da5618ecd40 Mon Sep 17 00:00:00 2001
From: Lou Knauer <lou.knauer@gmx.de>
Date: Fri, 20 Aug 2021 12:17:46 +0200
Subject: [PATCH] Reset encoder buffer in nats sink

---
 sinks/natsSink.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sinks/natsSink.go b/sinks/natsSink.go
index 6a938b8..77a0431 100644
--- a/sinks/natsSink.go
+++ b/sinks/natsSink.go
@@ -66,7 +66,7 @@ func (s *NatsSink) Write(measurement string, tags map[string]string, fields map[
 			return err
 		}
 		s.client.Publish(s.database, s.buffer.Bytes())
-
+		s.buffer.Reset()
 	}
 	return nil
 }