We got an requirement for implementation of JSON schema validation. Our application is Producer of the messages and these messages should be validated against its schema before placing them on a Kakfa topic.  This is to make sure only valid paylods/messages on to Topic.

I checked all functions and methods but did not find any.  Can anyone please provide details on how to achieve this requirement?.