Consider a Databricks job that processes real-time data from a Kafka stream, performs transformations, and loads the results into a database. The job has recently started failing due to changes in the Kafka schema. Describe the steps you would take to adapt the job to handle the new schema and ensure continuous operation.