Что делать с сообщениями, которые не можем обработать?

Так тоже спрашивают:

• Написан консьюмер, который читает из Kafka один топик, одну партицию. Копится лаг, в логах видна ошибка анмаршалинга данных (например, пришёл битый JSON). Как оперативно решить эту проблему?