Ótimo, 5 minutos depois de perguntar eu encontro a resposta. Vou postar aqui para referência futura:
Você precisa adicionar o
oplogReplay
sinalizar e defini-lo como true
. Isso só funciona se você também fizer uma consulta de intervalo no ts
campo. Eu tentei isso antes sem ter o intervalo definido e não fez nada. O código acima funciona quando você adiciona esta linha destacada abaixo:var cursorOptions = {
tailable: true,
awaitdata: true,
oplogReplay: true, // add this line
numberOfRetries: -1
};