микросервисов, обчитался и перепробовал. Но вот не догоняю все равно одну тему. Ну отправил я сообщение на шину, ну получил его кто то ... и... не справился, не отработал и получается все. Тот же sidekiq для рельсы, bull для ноды поверх redis будет пытаться дожать задачу, повторы и все такое. Нужно поверх kafka or nats писать проверку успешности и повторы делать?
Зачем?
Если сервис не смог обработать сообщение то это проблема сервиса что дальше делать. Если нужна повторная обработка, то DLQ. Жаль что нет из коробки, приходится велосипед изобретать
DLQ есть в RabbitMQ, вот как раз изучаю
А есть более-менее стандартизированный велосипед для DLQ?
я не нашел. Везде на слайдах красиво рассказано про стримы, джоины, но что делать с асинхронным обновлением сторов не упоминается.
в пульсаре тоже есть из коробки
Что не обязательно a good thing
Обсуждают сегодня