Merge pull request #4 from northvolt/bondeson/flush

Removed logging after flushing records
northvolt · May 19, 2021 · 4886478 · 4886478
2 parents ede83df + a65f54c
commit 4886478
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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,