Выполнение события akka-persistence-cassandra задерживается из-за пропущенных событий
Как часть кода akka-persistence-cassandra - событие, которое приходит с порядковым номером!= 1, инициирует поиск отсутствующей процедуры в случае, если порядковый номер 1 отсутствует в текущем временном интервале.
Поскольку события для одного и того же персистора могут приходить в очень разные времена (будут сохраняться в разные периоды времени), этот поток очень распространен в нашей системе.
Каждый поиск пропущенной процедуры будет блокировать наш поток до тех пор, пока он не сможет найти пропущенное событие, так как событие сохранялось в более раннем периоде времени, а поиск просматривал только текущий и предыдущий периоды времени - это займет ~10 секунд. в течение этих 10 секунд из потока не генерируются новые события, и это задержит выполнение событий, которые мы хотим выполнить
Есть ли обходной путь, чтобы отключить этот поиск недостающей процедуры и просто сохранить новое событие независимо от порядкового номера, с которым он прибывает?