need not to do a lot of changes... check your schema registry is valid and recording in logs...if there is an issue in schema, just check all the exceptions case and it check the requirement of null or void...this should solve your problem