Как вы обрабатывали сообщения из Kafka? Расскажи про валидацию — что происходило с невалидным сообщением?