From c3b7495cb73f7655afc11af077534f9cf882e096 Mon Sep 17 00:00:00 2001
From: Zhonghui Hu <“hzhonghu@amazon.com”>
Date: Thu, 22 Oct 2020 11:29:02 -0700
Subject: [PATCH] Make aggregation log statements debug level

---
 aggregate/aggregator.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/aggregate/aggregator.go b/aggregate/aggregator.go
index aa92155..0914d5a 100644
--- a/aggregate/aggregator.go
+++ b/aggregate/aggregator.go
@@ -108,7 +108,7 @@ func (a *Aggregator) AggregateRecords() (entry *kinesis.PutRecordsRequestEntry,
 	kclData := append(kclMagicNumber, protoBufData...)
 	kclData = append(kclData, md5CheckSum...)
 
-	logrus.Infof("[kinesis ] Aggregated (%d) records of size (%d) with total size (%d), partition key (%s)\n", len(a.records), a.getSize(), len(kclData), pkeys[0])
+	logrus.Debugf("[kinesis ] Aggregated (%d) records of size (%d) with total size (%d), partition key (%s)\n", len(a.records), a.getSize(), len(kclData), pkeys[0])
 
 	// Clear buffer if aggregation didn't fail
 	a.clearBuffer()