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,