Как решить проблему non-repeatable read и дедупликации на стороне консьюмера?