Genial, 5 minutos después de preguntar encuentro la respuesta. Publicaré esto aquí para futuras referencias:
Tienes que agregar el oplogReplay
marcar y establecerlo en true
. Esto solo funciona si también realiza una consulta de rango en ts
campo. Intenté esto antes sin tener el rango establecido y no hizo nada. El código anterior funciona cuando agrega esta línea resaltada a continuación:
var cursorOptions = {
tailable: true,
awaitdata: true,
oplogReplay: true, // add this line
numberOfRetries: -1
};