How to enforce a Kafka topic schema

TY3 — Sat, 16 Nov 2024 03:14:37 GMT

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?

topic How to enforce a Kafka topic schema in Talend Studio

How to enforce a Kafka topic schema