вам все ответили. Вы можете подвинуть офсет в топике, или вы можете пересоздать kafka таблицу чтобы она пропускала сломанные сообщения. Kafka engine не хранит ничего в КХ, она использует хранение commit offset в самой кафка, поэтому drop/create kafka engine абсолютно нормальный и единственный способ даже просто тупо добавить поля.
Обсуждают сегодня