From 7b18d1bab46f59a9b29e4f9dd588b9f10bf9ef70 Mon Sep 17 00:00:00 2001
From: Rafael Garcia <rafael.garcia@clever.com>
Date: Fri, 3 Nov 2017 18:03:39 +0000
Subject: [PATCH] write failed log message to file

---
 batchconsumer/batchermanager.go | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/batchconsumer/batchermanager.go b/batchconsumer/batchermanager.go
index a335b2f..2f74288 100644
--- a/batchconsumer/batchermanager.go
+++ b/batchconsumer/batchermanager.go
@@ -187,7 +187,13 @@ func (b *batcherManager) startMessageHandler(
 					batcher.AddMessage(tmp.msg, tmp.pair)
 				} else if err != nil {
 					lg.ErrorD("add-message", kv.M{
-						"err": err.Error(), "msg": string(tmp.msg), "tag": tmp.tag,
+						"err": err.Error(),
+						"tag": tmp.tag,
+					})
+					b.failedLogsFile.ErrorD("add-message", kv.M{
+						"err": err.Error(),
+						"msg": string(tmp.msg),
+						"tag": tmp.tag,
 					})
 				}
 				stats.Counter("msg-batched", 1)