Come hai gestito i messaggi di Kafka? Raccontami della validazione — cosa succedeva con un messaggio non valido?