задачи под эвент сорсинг очень редкие, прям крайне редкие. Это требует прям максимального обоснования. а так можешь использовать нативные Streams, у них реализован весь нужный функционал для очередей, включите objectMode и установите размер буффера объектов, через pipe обрабатывайте потоки трансформами