особенно если все происходит только под нагрузкой, я бы смотрел в сторону транзакций и коннектов мне кажется что транзакция по изменению не успевает коммитится иногда до того как вы начинаете обработку сообщения
кстати, у ващей сущности есть какое нибудь поле типа с наносекундами ? пишите это значение в сущность и сохраняйте в базу и его же добавьте в само сообщение а потом в консьюмере проверьте значения если не сходятся - дайте слип в 1 секунду и попробуйте передостать сообщение из базы если начнут сходится - вот вам и проблема
Запускается тут же, задержка небольшая (20-100мс) т к. консьюмер подписан на очередь. Фейлится на валидации состояния, так то и вырубить можно, но хотелось бы разобраться