No Schema Validation on Confluent Cloud

Question

I am using confluent cloud and currently i want to prevent messages with bad schema to ingest in my kafka topic. For that i am using schema management feature of confluent where i want to validate if the message is not matching the specified schema it should be rejected. I can produce this on confluent local but no rejection can be seen on cloud.

1. Does cloud currently support schema validation?
2. If not, do we have to implement it via kafka streams to validate schema ourselves?
3. Any reference to their official documentation for above answers? Or any document guiding this scenario for confluent cloud (not local) would be appreciated.

Thanks in advance

Answer 1

This is not properly described in their documentation. After contacting support got email describing:

At this time, we don't support broker side schema validation in Confluent Cloud, but the good news is it on the roadmap for furture support. I don't have an ETA for the release to share at this time.

I also see Robert Yokota (an engineer who also works in Confluent's Schema Registry team) confirm the same as well in the github issue you've provided.

Hope this helps. We'll be proceeding with case closure shortly.

Thanks,

Github issue referred above can be seen here