write failed log message to file

2017-11-03 18:03:39 +00:00 · 2017-11-03 18:03:39 +00:00 · 7b18d1bab4
commit 7b18d1bab4
parent 945ed317c2
1 changed files with 7 additions and 1 deletions
--- 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)