luciano/amazon-kinesis-client-go
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Added error message for failed log written to file

Browse source
This commit is contained in:
Xavi Ramirez 2018-12-11 16:32:33 -08:00
parent 23c68b42ff
commit e80ff2239b
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
batchconsumer/batchermanager.go
View file

@ -100,7 +100,7 @@ func (b *batcherManager) sendBatch(batcher *batcher, tag string) {
case PartialSendBatchError: case PartialSendBatchError:
lg.ErrorD("send-batch", kv.M{"msg": e.Error()}) lg.ErrorD("send-batch", kv.M{"msg": e.Error()})
for _, line := range e.FailedMessages { for _, line := range e.FailedMessages {
b.failedLogsFile.ErrorD("failed-log", kv.M{"log": line}) b.failedLogsFile.ErrorD("failed-log", kv.M{"log": line, "msg": e.Error()})
} }
stats.Counter("batch-log-failures", len(e.FailedMessages)) stats.Counter("batch-log-failures", len(e.FailedMessages))
case CatastrophicSendBatchError: case CatastrophicSendBatchError: