Я не думаю, что это возможно в настоящее время.Я думаю, что у вас есть два варианта:
в вашей модели чтения сохранить поток и индекс или позицию фиксации / подготовки события, а затем прочитать событие из потока $all
с помощью позиции фиксации / подготовкиили из потока было записано использование потока и индекса.Это, вероятно, самое простое.
Или создайте проекцию в хранилище событий, которая индексирует события по их идентификатору и перепроектирует в поток, называемый, скажем, eventid-{event.id}
, тогда вы можете читать непосредственно из этого потока.
Второй вариант обратно совместим с вашей текущей моделью чтения, но я не уверен, что это правильно, поскольку проекции вызывают усиление записи, и вам, вероятно, нужно убедиться, что вы исключаете системные события из проецируемого.