Так и вопрос, после выполнения чтения consumer прекращает работать, и его надо по новому запускать, понятно что можно через супераизор пнуть, но не завепшать же conusmer постоянно
А подскажите ответ на еще один вопрос: мне нравится валидировать данные через webmozzart/assett это один клас который предоставляет много статических методов для валидации. Хочу использовать его в доменном слое, и чтобы не было зависимости от внешнего пакета надписать его своим например Share или common.
а на счет ресенда сообщений, это может быть автоматически если вы бросаете ексепшн где-то в хендлере, тогда сообщение будет считаться необработанным и включится fail_retry логика