diff --git a/lib/oplog/tail.go b/lib/oplog/tail.go index e8717991..4c3d69aa 100644 --- a/lib/oplog/tail.go +++ b/lib/oplog/tail.go @@ -334,7 +334,8 @@ func (tailer *Tailer) unmarshalEntry(rawData bson.Raw) (timestamp *primitive.Tim entries := tailer.parseRawOplogEntry(result, nil) log.Log.Debugw("Received oplog entry", - "entry", result) + "entry", result, + "processTime", time.Now().UnixMilli()) status := "ignored" database := "(no database)"