From a65f54c26ccd8d3d71b386211b8c82cdf37918e1 Mon Sep 17 00:00:00 2001 From: Henrik Bondeson Date: Wed, 19 May 2021 11:20:01 +0200 Subject: [PATCH] Removed logging after flushing records --- producer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/producer.go b/producer.go index 07e5aaf..307c54e 100644 --- a/producer.go +++ b/producer.go @@ -242,7 +242,7 @@ func (p *Producer) flush(records []*kinesis.PutRecordsRequestEntry, reason strin defer p.semaphore.release() for { - p.Logger.Info("flushing records", LogValue{"reason", reason}, LogValue{"records", len(records)}) + //p.Logger.Info("flushing records", LogValue{"reason", reason}, LogValue{"records", len(records)}) out, err := p.Client.PutRecords(&kinesis.PutRecordsInput{ StreamName: &p.StreamName, Records: records,