Removed logging after flushing records

northvolt · May 19, 2021 · a65f54c · a65f54c
1 parent ede83df
commit a65f54c
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,