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
 }