Adds time.sleep in Kafka validation loop