Выполнение события akka-persistence-cassandra задерживается из-за пропущенных событий - PullRequest
0 голосов
/ 05 ноября 2018

Как часть кода akka-persistence-cassandra - событие, которое приходит с порядковым номером! = 1, инициирует поиск отсутствующей процедуры в случае, если порядковый номер 1 отсутствует в текущем временном интервале.

Поскольку события для одного и того же персистора могут приходить в разное время (будут сохраняться в разные периоды времени), этот поток очень распространен в нашей системе.

Каждый поиск недостающей процедуры блокирует наш поток до тех пор, пока он не сможет найти отсутствующее событие, так как событие сохранялось в более раннем периоде времени, а поиск просматривал только текущий и предыдущий периоды времени - это займет ~ 10 секунд. , в течение этих 10 секунд из потока не генерируются новые события, и это задержит выполнение событий, которые мы хотим выполнить

Есть ли обходной путь, чтобы отключить поиск недостающей процедуры и просто сохранить новое событие независимо от порядкового номера, с которым он прибывает?

...