Как обработвахте съобщенията от Kafka? Разкажете ми за валидирането — какво се случваше с невалидното съобщение?