Berdasarkan uraian masalahnya, saya pikir Anda memiliki kasus tidak ada antrian pesan yang terjadi. Hal ini dapat terjadi jika Anda memiliki banyak pesan yang berada dalam antrean, lalu berlangganan konsumen dengan auto-ack disetel ke true dan tidak ada jumlah prefetch. Jawaban ini
menjelaskan sedikit lebih detail apa yang terjadi dalam kasus ini.
Jika saya harus menebak, saya akan mengatakan kode javascript menghabiskan semua siklus yang dialokasikan untuk mengunduh pesan dari broker daripada memprosesnya menjadi Mongo. Menambahkan hitungan prefetch, sekaligus menonaktifkan auto-ack dapat menyelesaikan masalah Anda.
