message consistency test scenario in Kafka

i'm building a POC that contains a Kafka cluster deployed on Kubernetes and three spring boot apps that read from kafka and write to jms and vice versa.

I want to know how data integrity and consistency is ensured for example: If a producer node failed how the consumer is going to continue reading the message without losing the msg consistency. Is there a detailed scenario to test this feature.