I have a job that loads into a Kafka topic. We defined a schema on this topic at Kafka level. When i run my job, intentionally not conforming to the schema defined, it still works. We are expecting the job to throw some schema validation error and fail.
So, how do we let our Kafka job know that there is a schema on this topic; is there a property that we need to set?
