Спроектируй стратегию обработки ошибок consumer'а: что делать когда сообщение падает обработкой? Опиши DLQ, retry, poison-message-protection.