From e80ff2239b137eb1ff077c2d09aa200ee2a458c9 Mon Sep 17 00:00:00 2001 From: Xavi Ramirez Date: Tue, 11 Dec 2018 16:32:33 -0800 Subject: [PATCH] Added error message for failed log written to file --- batchconsumer/batchermanager.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/batchconsumer/batchermanager.go b/batchconsumer/batchermanager.go index 2f74288..cdfb281 100644 --- a/batchconsumer/batchermanager.go +++ b/batchconsumer/batchermanager.go @@ -100,7 +100,7 @@ func (b *batcherManager) sendBatch(batcher *batcher, tag string) { case PartialSendBatchError: lg.ErrorD("send-batch", kv.M{"msg": e.Error()}) 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)) case CatastrophicSendBatchError: